如何将Queue引用传递给pool.map_async（）管理的函数？

以下代码似乎有效：

import multiprocessing, timedef task(args):    count = args[0]    queue = args[1]    for i in xrange(count):        queue.put("%d mississippi" % i)    return "Done"def main():    manager = multiprocessing.Manager()    q = manager.Queue()    pool = multiprocessing.Pool()    result = pool.map_async(task, [(x, q) for x in range(10)])    time.sleep(1)    while not q.empty():        print q.get()    print result.get()if __name__ == "__main__":    main()

请注意，队列是从manager.Queue（）而不是multiprocessing.Queue（）获得的。感谢Alex向我指出了这个方向。