Python的学习之旅———生产者消费者模型

 1 from multiprocessing import Process,Queue,JoinableQueue
 2 import time
 3 import random
 4 
 5 def producer(name,food,q):
 6     for i in range(3):
 7         res='%s%s' %(food,i)
 8         time.sleep(random.randint(1,3))
 9         q.put(res)
10         print('%s 生产了 %s' %(name,res))
11 
12 def consumer(name,q):
13     while True:
14         res=q.get()
15         if res is None:break
16         time.sleep(random.randint(1, 3))
17         print('%s 吃了 %s' %(name,res))
18         q.task_done()
19 
20 if __name__ == '__main__':
21     q=JoinableQueue() #q.join()
22     p1=Process(target=producer,args=('egon','泔水',q))
23     p2=Process(target=producer,args=('贱哥','屎',q))
24     c1=Process(target=consumer,args=('alex',q))
25     c2=Process(target=consumer,args=('alex',q))
26     c3=Process(target=consumer,args=('alex',q))
27     c1.daemon=True
28     c2.daemon=True
29     c3.daemon=True
30 
31     p1.start()
32     p2.start()
33     c1.start()
34     c2.start()
35     c3.start()
36     
37     p1.join()
38     p2.join()
39     q.join()
40     print('主')