并发编程队列生产者消费者模型

from multiprocessing import Queue
q &＃61; Queue(3)q.put(&＃39;hello&＃39;)
q.put({&＃39;a&＃39;:1})
q.put([3,3,3])
print(q.full()) # 查看队列是否满了print(q.get())
print(q.get())
print(q.get())
q.empty() # 清空队列的数据
print(q.full())&＃39;&＃39;&＃39;
打印结果&＃xff1a;
True
hello
{&＃39;a&＃39;: 1}
[3, 3, 3]
False
&＃39;&＃39;&＃39;

from multiprocessing import Process,Queue
import timedef producer(q):for i in range(3):res &＃61; &＃39;包子%s&＃39; %itime.sleep(0.5)print(&＃39;生产者生产了%s&＃39; %res)q.put(res)# q.put(None) # 不能在这写的原因&＃xff1a;因为含有多个生产者&＃xff0c;生产者1生产结束后发送信号&＃xff0c;这时其他生产者还可能没有生产完&＃xff0c;消费者在取的时候&＃xff0c;碰到生产者1就结束了。def consumer(q):while True:res &＃61; q.get()if res is None:breaktime.sleep(1)print(&＃39;消费者吃了%s&＃39; %res)if __name__ &＃61;&＃61; &＃39;__main__&＃39;:#容器q &＃61; Queue()#生产者们p1 &＃61; Process(target&＃61;producer,args&＃61;(q,))p2 &＃61; Process(target&＃61;producer,args&＃61;(q,))p3 &＃61; Process(target&＃61;producer,args&＃61;(q,))#消费者们c1 &＃61; Process(target&＃61;consumer,args&＃61;(q,))c2 &＃61; Process(target&＃61;consumer,args&＃61;(q,))p1.start()p2.start()p3.start()c1.start()c2.start()p1.join() # 保证了p1这个进程执行完了
p2.join()p3.join()q.put(None)q.put(None)print(&＃39;主&＃39;)
&＃39;&＃39;&＃39;
打印结果&＃xff1a;
生产者生产了包子0
生产者生产了包子0
生产者生产了包子0
生产者生产了包子1
生产者生产了包子1
生产者生产了包子1
消费者吃了包子0
生产者生产了包子2
消费者吃了包子0
生产者生产了包子2
生产者生产了包子2
主
消费者吃了包子0
消费者吃了包子1
消费者吃了包子1
消费者吃了包子1
消费者吃了包子2
消费者吃了包子2
消费者吃了包子2
&＃39;&＃39;&＃39;

from multiprocessing import Process,JoinableQueue
import timedef producer(q):for i in range(2):res &＃61; &＃39;包子%s&＃39; %itime.sleep(0.5)print(&＃39;生产者生产了%s&＃39; %res)q.put(res)q.join() # 等队列执行完def consumer(q):while True:res &＃61; q.get()if res is None:breaktime.sleep(1)print(&＃39;消费者吃了%s&＃39; %res)q.task_done() # 可以告诉生产者,已经有一个数据被取走if __name__ &＃61;&＃61; &＃39;__main__&＃39;:#容器q &＃61; JoinableQueue()#生产者们p1 &＃61; Process(target&＃61;producer,args&＃61;(q,))p2 &＃61; Process(target&＃61;producer,args&＃61;(q,))p3 &＃61; Process(target&＃61;producer,args&＃61;(q,))#消费者们c1 &＃61; Process(target&＃61;consumer,args&＃61;(q,))c2 &＃61; Process(target&＃61;consumer,args&＃61;(q,))c1.daemon &＃61; Truec2.daemon &＃61; Truep1.start()p2.start()p3.start()c1.start()c2.start()p1.join()p2.join()p3.join()print(&＃39;主&＃39;)
&＃39;&＃39;&＃39;
打印结果&＃xff1a;
生产者生产了包子0
生产者生产了包子0
生产者生产了包子0
生产者生产了包子1
生产者生产了包子1
生产者生产了包子1
消费者吃了包子0
消费者吃了包子0
消费者吃了包子0
消费者吃了包子1
消费者吃了包子1
消费者吃了包子1
主
&＃39;&＃39;&＃39;