生产者与消费者模型，分布式系统

import time,random,multiprocessing
def produce(name,q):
    for i in range(20):
        time.sleep(random.randint(1,2))
        q.put(‘包子{}‘.format(i))
        print(‘{}生产了包子{}‘.format(name,i))
    # q.put(‘q‘)
def consumer(name,q):
    while True:
        time.sleep(random.randint(1,2))
        date=q.get()
        if date==‘q‘:
            break
        print(‘{} 吃了 {}‘.format(name,date))


if __name__ == ‘__main__‘:
    q=multiprocessing.Queue()
    p=multiprocessing.Process(target=produce,args=(‘egon‘,q))
    c=multiprocessing.Process(target=consumer,args=(‘alex‘,q))
    p.start()
    c.start()
    p.join()
    q.put(‘q‘)