Pathos 多处理池 CPickle 错误

Question

当我尝试运行以下代码时：

from pathos.multiprocessing import ProcessingPool as Pool
list1 = [1,2,3,4,5]
list2 = [6,7,8,9,10]
def function1(x,y):
    print x
    print y
if __name__ == '__main__':
    pool = Pool(5)
    pool.map(function1, list1, list2)

出现以下错误：

Traceback (most recent call last):
  File "test.py", line 9, in <module>
    pool.map(function1, list1, list2)
  File "C:\Python27\lib\site-packages\pathos\multiprocessing.py", line 136, in map
    return _pool.map(star(f), zip(*args)) # chunksize
  File "C:\Python27\lib\site-packages\multiprocess\pool.py", line 251, in map
    return self.map_async(func, iterable, chunksize).get()
  File "C:\Python27\lib\site-packages\multiprocess\pool.py", line 567, in get
    raise self._value
cPickle.PicklingError: Can't pickle <type 'function'>: attribute lookup __builtin__.function failed

pathos.multiprocessing不就是为了解决这个问题吗？

Answer 1

我是 pathos 作者。当我尝试你的代码时，我没有收到错误。但是，如果您看到 CPickle.PicklingError，我猜您的 multiprocess 安装有问题。你在 windows，所以你有 C 编译器吗？ multiprocess 需要一个才能完整安装 multiprocess.

Pathos 多处理池 CPickle 错误

Pathos multiprocessing pool CPickle error

python

multiprocessing

pathos