pathos.multiprocessing 有星图吗？

执行下面的代码时出现错误。问题似乎是map不支持接受多个输入的函数，就像 python 内置函数一样multiprocessing包裹。但是内置的包里有一个starmap这解决了这个问题。做pathos.multiprocessing有相同的吗？

import pathos.multiprocessing as mp


class Bar:
    def foo(self, name):
        return len(str(name))

    def boo(self, x, y, z):
        sum = self.foo(x)
        sum += self.foo(y)
        sum += self.foo(z)
        return sum


if __name__ == '__main__':
    b = Bar()
    pool = mp.ProcessingPool()
    results = pool.map(b.boo, [(12, 3, 456), (8, 9, 10), ('a', 'b', 'cde')])
    print(results)

类型错误：boo() 缺少 2 个必需的位置参数：“y”和“z”

按照建议更新 lambda 表达式（不起作用）：

if __name__ == '__main__':
    b = Bar()
    pool = mp.ProcessingPool()
    results = pool.map(lambda x: b.boo(*x), [(12, 3, 456), (8, 9, 10), ('a', 'b', 'cde')])
    print(results)

multiprocessing.pool.RemoteTraceback：

"""

回溯（最近一次调用最后一次）：

文件 “C：\ Users \ yg451 \ Anaconda3 \ lib \ site-packages \ multiprocess \ pool.py”， 第 121 行，在工人中

结果 = (True, func(*args, **kwds))

文件 “C：\ Users \ yg451 \ Anaconda3 \ lib \ site-packages \ multiprocess \ pool.py”， 地图之星 44 号线

返回列表（地图（*args））

文件 “C：\ Users \ yg451 \ Anaconda3 \ lib \ site-packages \ pathos \ helpers \ mp_helper.py”， 15号线，在

func = lambda 参数：f(*args)

文件“C:/Users/yg451/Code/foo/Machine Learning/xPype/test/scratch.py​​”，第 18 行，

结果 = pool.map(lambda x: b.boo(*x), [(12, 3, 456), (8, 9, 10), ('a', 'b', 'cde')])

NameError：名称“b”未定义

"""

I'm the pathos作者。pathos比starmap，并且并不真正需要它。它解决池中的多个参数的方式与内置的完全相同map does.

>>> import pathos.multiprocessing as mp
>>> class Bar:
...     def foo(self, name):
...         return len(str(name))
...     def boo(self, x, y, z):
...         sum = self.foo(x)
...         sum += self.foo(y)
...         sum += self.foo(z)
...         return sum
... 
>>> b = Bar()
>>> pool = mp.ProcessingPool()
>>> f = lambda x: b.boo(*x)    
>>> results = pool.map(f, [(12, 3, 456), (8, 9, 10), ('a', 'b', 'cde')])
>>> results 
[6, 4, 5]
>>> results = pool.map(b.boo, [12, 9, 'a'], [3, 9, 'b'], [456, 10, 'cde'])
>>> results
[6, 4, 5]
>>> results = map(b.boo, [12, 9, 'a'], [3, 9, 'b'], [456, 10, 'cde'])
>>> list(results)
[6, 4, 5]
>>> 

所以，本质上，starmap是不必要的。然而，由于它最近被添加到标准中Pool接口在multiprocessing在某些版本的 python 中，它可能应该更加突出pathos。请注意，已经可以获得“增强”版本starmap from pathos如果你喜欢。

>>> import pathos
>>> mp = pathos.helpers.mp
>>> p = mp.Pool()
>>> p.starmap
<bound method Pool.starmap of <multiprocess.pool.Pool object at 0x1038684e0>>
>>>