我可以將方法傳遞給apply_async或map在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需要醃製self.f同時綁定方法不是picklable的事實。有關於如何解決問題的討論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()