import random

 import time

 from multiprocessing import Queue, Process

 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)

 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))

 if __name__ == '__main__':

     q = Queue(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.start()

     c2.start()

     p1.join()

     p2.join()

     q.put(None)