如何恢复传递给multiprocessing.Process的函数的返回值？

Question

如何恢复传递给multiprocessing.Process的函数的返回值？在下面的示例代码中，我想恢复函数的返回值worker。我该怎么做呢？这个值存储在哪里？示例代码：import multiprocessingdef worker(procnum):    '''worker function'''    print str(procnum) + ' represent!'    return procnumif __name__ == '__main__':    jobs = []    for i in range(5):        p = multiprocessing.Process(target=worker, args=(i,))        jobs.append(p)        p.start()    for proc in jobs:        proc.join()    print jobs输出：0 represent!1 represent!2 represent!3 represent!4 represent![<Process(Process-1, stopped)>, <Process(Process-2, stopped)>, <Process(Process-3, stopped)>, <Process(Process-4, stopped)>, <Process(Process-5, stopped)>]我似乎无法在存储的对象中找到相关属性jobs。

Answer 1

使用共享变量进行通信。例如这样：

import multiprocessingdef worker(procnum, return_dict):
    '''worker function'''
    print str(procnum) + ' represent!'
    return_dict[procnum] = procnumif __name__ == '__main__':
    manager = multiprocessing.Manager()
    return_dict = manager.dict()
    jobs = []
    for i in range(5):
        p = multiprocessing.Process(target=worker, args=(i,return_dict))
        jobs.append(p)
        p.start()

    for proc in jobs:
        proc.join()
    print return_dict.values()

Answer 2

简单的解决方案：

import multiprocessing

output=[]data = range(0,10)def f(x):
    return x**2def handler():
    p = multiprocessing.Pool(64)
    r=p.map(f, data)
    return rif __name__ == '__main__':
    output.append(handler())print(output[0])

输出：

[0, 1, 4, 9, 16, 25, 36, 49, 64, 81]