生產者消費者模型 守護線程
守護線程
守護線程會在主線程結束就立即結偶完成束,即使任務沒有完成
主線程會等待所有子線程全部完成最後結束
結論 :守護線程會在所有非守護進程結束後結束
from threading import Thread,current_thread
import time
def task1():
print("%s正在運行...."%current_thread().name)
time.sleep(3)
print("%s over...."%current_thread().name)
def task2():
print("%s 正在運行..."%current_thread().name)
print("over...."%current_thread().name)
t1 = Thread(target = task1)
t2 = Thread(target = task2)
t1.daemon = True #守護線程必須放在start前面
t1.start()
t2.start()
print("over")
生產者消費者模型
例子:
王思聰作為消費者 要吃熱狗
生產者負責做熱狗
問題是不知道:王思聰不清楚對方會生產多少熱狗
from multiprocessing import Process Queue,JoinableQueue
def make_hot_dog():
for i in range(1,6):
time.sleep(random.randint(1,3))
print(‘生產者 生產了hot_dog%s ‘ %i)
q.put("hot_dog%s"%i)
def eat_hot_dog():
while True:
time.sleep(random.randint(1,3))
hot_dog = q.get()
print("思聰吃了%s" %hot_dog)
q.task_done()
if __name__ =="__main__":
q = JoinableQueue()
p1 = Process(target = mak_hot_dog,args = (q,))
p2 = Process(target = mak_hot_dog,args = (q,)
p1.start()
p2.start()
#消費者
c1 = Process(target = eat_hot_dog,args = (q,)
c1.daemon = True
c1.start()
#要確定生產者不會再生產了
p1.join()
p2.join()
print("生產已經結束了“)
#再確定隊列中的所有數據都被處理完成
q.join()
print("思聰已經全部吃完了“)
生產者消費者模型 守護線程