from multiprocessing import Process,Queue
import time
import random
import os
def consumer(q):
while True:
res=q.get()
if res is None:
break
time.sleep(random.randint(1,3))
print('%s 吃了 %s' % (os.getpid(), res))
def producer(q):
for i in range(5):
time.sleep(2)
res='包子%s' %i
q.put(res)
print('%s 制造了 %s' %(os.getpid(),res))
q.put(None)
if __name__ == '__main__':
q=Queue()
#生产者们:厨师们
p1=Process(target=producer,args=(q,))
#消费者们:吃货们
p2=Process(target=consumer,args=(q,))
p1.start()
p2.start()
p1.join()
p2.join()
print('主')