マルチプロセッシングの結果を得る方法.Pool.apply_async

Question

PythonでPool.apply_asyncで実行された関数の結果を得たいと思います。

結果を親プロセスの変数に代入する方法はありますか？私はコールバックを使用しようとしましたが、それは複雑に思えます。

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を更新する、それがあなたのコールバックを呼び出します、結果を計算します。

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

まあ簡単な方法は、次のようにヘルパークラスを持っているだろう。

いずれにしても、スレッドが終了したことを確認する必要があります。