python-阻塞线程和守护线程

一、线程的创建

【1】threading.Thread创建一个线程,返回一个对象,用变量接收

【2】变量.start启动线程

# -*- coding:utf-8 -*- # __author__: # 2022/5/10  # GIL:全局解释器锁,只允许 同一时间只允许1个线程进入CPU,所以cpython中没有并行,是并发 import threading,time  def foo(st):     for i in range(5):         time.sleep(1)         print(st)  # 1、threading.Thread创建一个线程,返回一个对象 # 2、args入参是个元祖,所以括号最后要加上逗号;入参即foo函数的入参 # 3、target是目标函数 t1 = threading.Thread(target=foo,args=('消费数据1',)) t2 = threading.Thread(target=foo,args=('消费数据2',))  # 启动线程 t1.start() t2.start()

【3】以上代码最终结果是, '消费数据1'和'消费数据2'和换行符,并发进行,执行完后结束

二、阻塞线程join

【1】join阻塞父线程:在子线程没有执行完成之前,阻塞父线程;当子线程全都执行完成后,继续执行父线程

# -*- coding:utf-8 -*- # __author__: # 2022/5/10  import threading  def foo(st):     for i in range(5):         print(st)  t1 = threading.Thread(target=foo,args=('生产数据1',)) t2 = threading.Thread(target=foo,args=('生产数据2',))  t1.start() t2.start()  # join阻塞父线程:在子线程没有执行完成之前,阻塞父线程;当子线程全都执行完成后,继续执行父线程 # 运行.py文件的时候,.py文件的代码运行相当于主(父)线程,两个创建的t1t2相当于子线程 t1.join() t2.join()  # 父线程中的代码 print('继续执行父线程')

【2】以上代码运行结果是:当t1和t2的并发线程结束后,才会执行主线程中的print语句

三、守护线程daemon

【1】当没有守护线程的时候,如果主线程运行完毕,此时子线程还没运行结束,则主线程会等所有子线程运行完毕后再结束
【2】当有守护线程的时候,如果主线程运行完毕,子线程还没运行完毕,则主线程仍会结束,不会等待子线程
【3】 声明守护线程,必须在线程start启动之前

# -*- coding:utf-8 -*- # __author__:pansy # 2022/5/10 import threading  def foo(st):     for i in range(5):         print(st)  t1 = threading.Thread(target=foo,args=('消费数据1',)) t2 = threading.Thread(target=foo,args=('消费数据2',))  # 当没有守护线程的时候,如果主线程运行完毕,此时子线程还没运行结束,则主线程会等所有子线程运行完毕后再结束 # 当有守护线程的时候,如果主线程运行完毕,子线程还没运行完毕,则主线程仍会结束,不会等待子线程 # 声明守护线程,必须在线程start启动之前 t1.daemon = True t2.daemon = True  t1.start() t2.start()  print('消费数据结束。。。。。')

【4】以上代码的结果是:当出现打印'消费数据结束。。。。。'时,表示主线程结束,不会等待子线程,此时不会继续打印'消费数据1'和'消费数据2'