如何编写使用并行计算对列表求和的函数?

将作业调度到Python时 Pool 您需要确保函数及其参数都可以序列化,因为它们将通过 pipe .

Python使用 pickle 序列化其对象的协议。你可以看到在 module documentation . 在您的情况下,您面临着这个限制。

在模块顶层定义的函数(使用def,而不是lambda)

在引擎盖下 水塘 正在发送包含函数名及其参数的字符串。子进程中的Python解释器在模块中查找该函数名,但由于它嵌套在另一个函数的作用域中,因此找不到该函数名 parallelSum .

移动 sumPartLocal 外部 平行和 一切都会好起来的。

我相信你在打 this ,或查看 documentation

你能做的就是离开 def sumPartLocal 在模块级,通过 theArray 作为您的 tuple 那就是 fromTo[2] 内部 sumPartLocal 作用

例子:

from multiprocessing import Pool

def sumPartLocal(fromTo: tuple):
    return sum(fromTo[2][fromTo[0]:fromTo[1]]) 

def parallelSum(theArray):
    with Pool(2) as pool:
        return (sum
                (pool.map
                 (sumPartLocal, [
                     (0, len(theArray) // 2, theArray), 
                     (len(theArray) // 2, len(theArray), theArray)
                     ]
                  )
                 )
                )

if __name__ == '__main__':
    theArray = 100000000*[1]
    s = parallelSum(theArray)
    print(s)

[根据评论编辑2017年12月15日]

任何想在python中使用多线程的人,我强烈建议阅读 Global Interpreter Lock

还有,关于这个问题的一些好答案 question here on SO