Python--day38--JoinableQueue解决生产者消费者模型

#############################

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

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

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

生产者消费者模型.py

import random
import time
from multiprocessing import JoinableQueue, Process

def consumer(q,name):
    while True:
        food = q.get()
        if food is None:
            print('%s获取到了一个空',name)
            break
        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)    #0 1 ...20
    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()感知一个进程的结束
    q.put(None)