python学习-pipe管道实现生产消费

[root@localhost /]#
[root@localhost /]# cat zhu.py
#!/bin/python
import multiprocessing
import random
import time
import os
def producer(pipe):
    while True:
        time.sleep(1)
        item = random.randint(1, 10)
        print('process producer product goods:{}'.format(item))
        pipe.send(item)
        time.sleep(1)
def consumer(pipe):
    while True:
        time.sleep(1)
        item = pipe.recv()
        print('process cusumer get goods:{}'.format(item))
        time.sleep(1)
if __name__ == "__main__":
    pipe = multiprocessing.Pipe()
    process_producer = multiprocessing.Process( target=producer, args=(pipe[0],))
    process_consumer = multiprocessing.Process( target=consumer, args=(pipe[1],))
    process_producer.start()
    process_consumer.start()
    process_producer.join()
    process_consumer.join()

[root@localhost /]#