是否可以在 Python 中对返回某些内容的函数进行多处理？

在Python中，我见过很多调用多重处理但目标只是打印一些东西的例子。我有一个场景，目标返回 2 个变量，稍后我需要使用它们。例如：

def foo(some args):
   a = someObject
   b = someObject
   return a,b

p1=multiprocess(target=foo,args(some args))
p2=multiprocess(target=foo,args(some args))
p3=multiprocess(target=foo,args(some args))

怎么办？我可以执行 .start 和 .join，但如何检索各个结果？我需要捕获我执行的所有作业的返回 a,b，然后对其进行处理。

您正在寻求使用多个进程来完成一些令人尴尬的并行工作，那么为什么不使用Pool? A Pool将负责启动流程、检索结果并将结果返回给您。

I use pathos，其中有一个叉子multiprocessing，因为它比标准库提供的版本具有更好的序列化能力。

(.py) 文件

from pathos.multiprocessing import ProcessingPool as Pool

def foo(obj1, obj2):
    a = obj1.x**2
    b = obj2.x**2
    return a,b

class Bar(object):
    def __init__(self, x):
        self.x = x

Pool().map(foo, [Bar(1),Bar(2),Bar(3)], [Bar(4),Bar(5),Bar(6)])

Result

[(1, 16), (4, 25), (9, 36)]

你看到了foo接受两个参数，并返回两个对象的元组。这map的方法Pool提交foo到底层进程并将结果返回为res.

你可以得到pathos here: https://github.com/uqfoundation https://github.com/uqfoundation