如何将函数的返回值附加到Pool中的列表中？

Question

我很好奇是否可以将函数f(x,y)的返回值附加到例如list中.

所以我有这个:

平行:

 def download_unit_LVs(self, cislo_uzemia):
     pool = Pool(number_of_workers)
     for cislo in cisla:
         pool.apply_async(self.download_cislo, args=(cislo_uzemia,cislo))
     pool.close()
     pool.join()
     self.manager.commit()

这是我运行方法self.download_cislo并行的方法,但问题是,它返回一个我必须附加到结果列表的值.

怎么做？

顺序:

 def download_unit_LVs(self, cislo_uzemia):
        results = []
        for cislo in cisla:
            results.append(self.download_cislo(cislo_uzemia,cislo))
        self.manager.commit()

Answer 1

该pool.apply_async调用可以通过一个callback 函数.foo函数完成时将调用回调函数,并将传递返回的值foo.请注意,返回值必须是可选择的,因为进程之间的通信是使用Queue完成的.

import multiprocessing as mp

def foo(x):
    return x * x

if __name__ == '__main__':
    result = []
    pool = mp.Pool()
    for i in range(100):
        pool.apply_async(foo, args=(i, ), callback=result.append)
    pool.close()
    pool.join()
    print(result)
    # [0, 1, 4, 9, 16, ... 9409, 9604, 9801]