概述

当使用进程池Pool实现多进程时，实现进程间通信，需要multiprocessing.Manager()的Queue，使用方式同multiprocessing.Queue

案例

#coding=utf-8

from multiprocessing import Pool,Manager

def putdata(qu):
    for i in range(10):
        qu.put(i)

def getdata(qu):
    while not qu.empty():
        print(qu.get())

if __name__ == "__main__":
    q=Manager().Queue()
    pool=Pool()
    pool.apply_async(putdata,(q,))
    pool.apply_async(getdata,(q,))
    pool.close()
    pool.join()

原文出处：/show_1EF2xrvqDp6v.html