实现生产消费原理
from multiprocessing import Process,JoinableQueue
import time
import random
def cooker(q):
x = random.randint(1,100)
q.put(f'hz厨师抄了{x}碗蛋炒饭')
def eatter(q):
while True:
food = q.get()
time.sleep(2)
print(f'lxt吃了{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()