Python进程间通信（生产者/消费者模型、pipe）

    import multiprocessing
    # 线程通信=====(队列) ---- from queue import Queue
    # 进程池中进程通信=====(队列) --- from multiprocess.Manager import Queue
    # 多进程通信=========(队列)   ---- from multiprocess import Queue
    import time
    class Producer(multiprocessing.Process):
    def __init__(self, queue):
        super(Producer, self).__init__()
        self.queue = queue
    def run(self):
        # 将需要通信的数据写入队列中;
        for i in range(10):
            self.queue.put(i)
            time.sleep(0.1)
            print("传递消息， 内容为%s" %