1. 程式人生 > >生產者消費者模型 守護線程

生產者消費者模型 守護線程

ssi 負責 tar def thread random rom 問題 join

守護線程

  守護線程會在主線程結束就立即結偶完成束,即使任務沒有完成

  主線程會等待所有子線程全部完成最後結束

  結論 :守護線程會在所有非守護進程結束後結束

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)

  time.sleep(10)
  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

import time,random

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("思聰已經全部吃完了“)

生產者消費者模型 守護線程