python基础一 day37 JoinableQueue

r囧r小猫 2024-04-20 11:06 98阅读 0赞

import time  
import random  
from multiprocessing import Process,JoinableQueue  
def consumer(q,name):  
while True:  
food = q.get()  
print('\\033\[31m%s消费了%s\\033\[0m' % (name,food))  
time.sleep(random.randint(1,3))  
q.task\_done() \# count - 1

def producer(name,food,q):  
for i in range(4):  
time.sleep(random.randint(1,3))  
f = '%s生产了%s%s'%(name,food,i)  
print(f)  
q.put(f)  
q.join() \# 阻塞 直到一个队列中的所有数据 全部被处理完毕

if \_\_name\_\_ == '\_\_main\_\_':  
q = JoinableQueue(20)  
p1 = Process(target=producer,args=('Egon','包子',q))  
p2 = Process(target=producer, args=('wusir','泔水', q))  
c1 = Process(target=consumer, args=(q,'alex'))  
c2 = Process(target=consumer, args=(q,'jinboss'))  
p1.start()  
p2.start()  
c1.daemon = True \# 设置为守护进程 主进程中的代码执行完毕之后,子进程自动结束  
c2.daemon = True  
c1.start()  
c2.start()  
p1.join()  
p2.join() \# 感知一个进程的结束

\# 在消费者这一端:  
\# 每次获取一个数据  
\# 处理一个数据  
\# 发送一个记号 : 标志一个数据被处理成功

\# 在生产者这一端:  
\# 每一次生产一个数据,  
\# 且每一次生产的数据都放在队列中  
\# 在队列中刻上一个记号  
\# 当生产者全部生产完毕之后,  
\# join信号 : 已经停止生产数据了  
\# 且要等待之前被刻上的记号都被消费完  
\# 当数据都被处理完时,join阻塞结束

\# consumer 中把所有的任务消耗完  
\# producer 端 的 join感知到,停止阻塞  
\# 所有的producer进程结束  
\# 主进程中的p.join结束  
\# 主进程中代码结束  
\# 守护进程(消费者的进程)结束

转载于:https://www.cnblogs.com/wang-tan/p/11435552.html