import time

import random

from multiprocessing import Queue

from multiprocessing import Process

def producer(q,food):

    for i in range(5):

        q.put('%s-%s'%(food,i))

        print('生产了%s'%food)

        time.sleep(random.random())

    q.put(None)

    q.put(None)

    q.put(None)#有三个消费者因此需要三个信号

def consumer(q,name):

    while True:

        food = q.get()

        if food == None:break

        print('%s 吃了 %s'%(name,food))

if __name__ == '__main__':

    q = Queue()

    p1 = Process(target=producer,args=(q,'菠萝蜜干'))

    p1.start()

    p2 = Process(target=producer, args=(q, '酸奶'))

    p2.start()

    c1 = Process(target=consumer, args=(q, 'Rabbit'))

    c1.start()

    c2 = Process(target=consumer, args=(q, 'OrangeCat'))

    c2.start()

    c3 = Process(target=consumer, args=(q, 'CuiHua'))

    c3.start()

import time

import random

from multiprocessing import Process

from multiprocessing import JoinableQueue

def producer(q,food):

    for i in range(5):

        q.put('%s-%s'%(food,i))

        print('生产了%s'%food)

        time.sleep(random.random())

    q.join()  # 等待消费者把所有的数据都处理完

def consumer(q,name):

    while True:

        food = q.get()   # 生产者不生产还是生产的慢

        print('%s 吃了 %s'%(name,food))

        q.task_done()#JoinableQueue内部自带计数功能，每执行一次task_done，计数减一。

if __name__ == '__main__':
    q = JoinableQueue()
    p1 = Process(target=producer,args=(q,'炒河粉'))
    p1.start()
    p2 = Process(target=producer, args=(q, '草莓'))
    p2.start()
    c1 = Process(target=consumer, args=(q, 'Rabbit'))
    c1.daemon = True
    c1.start()
    c2 = Process(target=consumer, args=(q, 'Orange_Cat'))
    c2.daemon = True
    c2.start()
    c3 = Process(target=consumer, args=(q, 'Teddy'))
    c3.daemon = True
    c3.start()

    p1.join()  # 等待p1执行完毕
    p2.join()  # 等待p2执行完毕