使用 python 进行多处理

Question

我如何控制这个函数池apply_asyn的返回值 假设我有以下很酷的内容，

import multiprocessing:


de fun(..)
...
...
return value


my_pool = multiprocessing.Pool(2)


for i in range(5) :
    result=my_pool.apply_async(fun, [i])

 some code going to be here....

digest_pool.close()
digest_pool.join()
here i need to proccess the results 

我如何控制每个进程的结果值并知道检查它属于哪个进程，

Answer 1

存储 for 循环中“i”的值，然后打印它或返回并将其保存在其他地方。
因此，如果发生一个进程，您可以通过查看变量 i 来检查它是来自哪个进程。

希望这有帮助。

Answer 2

您确定需要知道您的两名员工中哪一位正在做什么？在这种情况下，您可能最好使用进程和队列，因为这听起来需要多个进程之间进行一些通信。

如果您只想知道哪个结果由哪个工作进程处理，您可以简单地返回一个元组：

#!/usr/bin/python
import multiprocessing

def fun(..)
...
    return value, multiprocessing.current_process()._name

my_pool = multiprocessing.Pool(2)
async_result = []

for i in range(5):
    async_result.append(my_pool.apply_async(fun, [i]))

# some code going to be here....

my_pool.join()
result = {}
for i in range(5):
    result[i] = async_result[i].get()

如果您有不同的输入变量作为列表，则 map_async 命令可能是更好的决定

#!/usr/bin/python
import multiprocessing

def fun(..)
...
...
    return value, multiprocessing.current_process()._name

my_pool = multiprocessing.Pool()

async_results = my_pool.map_async(fun, range(5))

# some code going to be here....

results = async_results.get()

：最后一行加入池。请注意，结果是一个元组列表，每个元组包含您的计算值和计算该值的进程的名称。