代码:
import threading
import queue
#消费者与生产者模式去实现我们可重复利用的线程
#主线程为生产者,子线程为消费者
class Mythread(threading.Thread):
def __init__(self):
super().__init__()
self.q = queue.Queue()
self.daemon = True #设置守护线程,主线程结束,子线程接着结束
self.start()
def run(self): #run里面的东西是在我们的子进程里面去执行,且只有run是在子进程里面
while True:
func,args,kwargs = self.q.get() #拿任务
func(*args,**kwargs) #执行任务
self.q.task_done()
def pro(self,func,args = (),kwargs = {}): #定义生产者函数
self.q.put((func,args,kwargs))
def join(self):
self.q.join() #阻塞,直到计数器为0
def func1(*args,**kwargs):
print("一",args,kwargs)
def func2(*args,**kwargs):
print("二",args,kwargs)
t = Mythread()
# t.start() #可以写在类定义的init函数中,省去这一步
t.pro(func1,args = (1,2,3),kwargs={"name":"A","age":15})
t.pro(func2,(2,3),{"name":"B","age":14})
t.join()
print("结束 ")
图例: