apply_asyncにメソッドを渡したり、Pythonマルチプロセッシングでマップすることはできますか？

Question

次のように動作させるにはどうすればよいですか？要点は、非同期にメソッドを（そして関数ではなく）実行したいということです。

from multiprocessing import Pool 

class Async: 
    def __init__(self, pool): 
     self.pool = pool 
     self.run() 

    def run(self): 
     p.apply_async(self.f, (10,)) 

    def f(self, x): 
     print x*x 

if __name__ == '__main__': 
    p = Pool(5) 
    a = Async(p) 
    p.close() 
    p.join() 

これは何も印刷しません。

Answer 1

問題はmultiprocessingがバインドメソッドはpickle化可能なない間self.fを酸洗する必要があるという事実のためであると思われます。この問題を解決する方法については、hereを参照してください。

apply_asyncは明らかに未来に返される例外を作成します。それが何も印刷されていない理由です。 getが将来実行されると、例外が発生します。

Answer 2

Python 2でスレッドプールを使用してクラスメソッドをスレッドすることは間違いありません。次のプログラムは、私が期待したことを行いました。

#!/usr/bin/env python 

from multiprocessing.pool import ThreadPool 

class TestAsync(): 
    def __init__(self): 
    pool = ThreadPool(processes = 2) 

    async_completions = [] 
    for a in range(2): 
     async_completions.append(pool.apply_async(self.print_int, ( a,))) 

    for completion in async_completions: 
     res = completion.get() 
     print("res = %d" % res) 

    def print_int(self, value): 
    print(value) 
    return (value*10) 


a = TestAsync()