在应用异步 Python 函数中调用应用异步

Question

我正在尝试调用一个带有apply_async函数内部的池，当我尝试将一个函数传递给另一个函数的池时，我收到序列化对象的错误，所以我将第二个池移动到全局，但它仍然对我不起作用，我错过了什么？我的代码 ：

from multiprocessing import Pool
b_pool = Pool(1)
def func_a(i):
    global b_pool
    print "a : {}".format(i)
    try:
        res = b_pool.apply_async(func_b, args=(i,))
    except Exception as e:
        print e
def func_b(i):
    print "b : {}".format(i)
    file = "/home/ubuntu/b_apply.txt"
    f = open(file, "a")
    f.write("b : {}".format(i))
    f.close()

if __name__ == '__main__':
    a_pool = Pool(1)
    for i in range(10):
       res =  a_pool.apply_async(func_a,args=(i,) )
    a_pool.close()
    a_pool.join()
    b_pool.close()
    b_pool.join()

在此代码中，只有 A 打印 0 -9，B 不打印甚至不打印到文件。我正在使用 Python 2.7

Answer 1

队列是很好的方向，只是那个多处理。队列不能像这样传递，但 Manager.Queue 是执行此操作的正确方法，我的代码有效：

from multiprocessing import Pool,Manager
def func_a(i,q):
    print "a : {}".format(i)
    try:
        q.put(i)
    except Exception as e:
        print e

def func_b(i,q):
    i = q.get()
    print "b : {}".format(i)

if __name__ == '__main__':
    m = Manager()
    q = m.Queue()
    a_pool = Pool(1)
    b_pool = Pool(1)
    for i in range(10):
        res = a_pool.apply_async(func_a,args=(i,q,) )
        res_2 = b_pool.apply_async(func_b, args=(i,q,))
    a_pool.close()
    a_pool.join()
    b_pool.close()
    b_pool.join()

这个答案在几个进程之间共享结果队列非常有帮助