如何获得多处理结果.Pool.apply_async

Question

我想在Python中获取运行函数Pool.apply_async的结果。

如何将结果分配给父进程中的变量？我试图使用回调，但似乎很复杂。

Answer 1

的解决方案很简单：

import multiprocessing 

def func(): 
    return 2**3**4 

p = multiprocessing.Pool() 
result = p.apply_async(func).get() 
print(result) 

由于Pool.apply_async()返回一个AsyncResult，你可以简单地得到从AsyncResult.get()方法的结果。

希望这会有所帮助！

Answer 2

那么一个简单的方法是将有一个辅助类是这样的：

class Result(): 
    def __init__(self): 
     self.val = None 

    def update_result(self, val): 
     self.val = val 

result = Result() 

def f(x): 
    return x*x 

pool.apply_async(f, (10,), callback=result.update_result) 

当线程运行，并计算出结果，它会调用你的回调将更新result.val。

无论如何您需要检查线程是否完成。