PYthon-4.23作业

实现生产消费原理

from multiprocessing import Process,JoinableQueue
import time
import random

def cooker(q):
    x = random.randint(1,100)
    q.put(f'蒸了{x}个熊掌')

def eatter(q):
    while True:
        food = q.get()
        time.sleep(1)
        print(f' 我吃了{food}')
        q.task_done()

if __name__ == '__main__':
    # q = Queue(4)
    q = JoinableQueue()
    c1 = Process(target=cooker,args=(q,))
    c2 = Process(target=cooker,args=(q,))
    c3 = Process(target=cooker,args=(q,))
    e = Process(target=eatter,args=(q,))
    c1.start()
    c2.start()
    c3.start()
    c1.join()
    c2.join()
    c3.join()
    e.daemon = True
    e.start()
    q.join()