如何獲得以下功能?重點是我想異步運行一個方法(而不是一個函數)。我可以將方法傳遞給apply_async或map在python多處理中嗎?
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()
這不打印任何東西。
適當添加a.run()。 – Simon
修正了運行方法。我發現這個可能的解決方案:http://stackoverflow.com/q/1816958/1545579必須嘗試...也許它有幫助...將更新 – Mahdi