另一个与多处理错误混淆的是,“module”对象没有属性“f”

重新构造代码,以便 f() 函数是在创建池实例之前定义的。否则工人看不到您的功能。

#!/usr/bin/python
# -*- coding: utf-8 -*-

from multiprocessing import Pool

def f(x):
    return x*x

p = Pool(1)
p.map(f, [1, 2, 3])

这个有效:

#!/usr/bin/python
# -*- coding: utf-8 -*-
from multiprocessing import Pool

def f(x):
    return x*x

if __name__ == "__main__":
    p = Pool(1)
    p.map(f, [1, 2, 3])

我不确定为什么你的代码不能工作,但我想原因是 multiprocessing 模块尝试导入主模块(以访问您定义的方法),然后 if __name__ == "__main__" 节不需要在设置池的位置执行初始化代码。

一种可能是python文件与模块同名:

• Py
• 试验/
  • π介子

在pickle.py中,错误来自:

    def find_class(self, module, name):
      # Subclasses may override this
      __import__(module)
      mod = sys.modules[module] # <- here mod will reference your test/__init__.py
      klass = getattr(mod, name)
      return klass

我的问题通过使用 if __name__ == "__main__" 正如tam's所指出的,在eclipse for windows中,示例在解释器下不起作用。 这在 http://docs.python.org/2/library/multiprocessing

这是因为 p = Pool(1) 主进程在创建函数f之前分叉进程(线程与进程)。正如bartosz中所述,派生进程没有访问新函数的权限。

def f1(x):
    ...

p = Pool(1) # p is spawned and is now an independent process, knows f1

def f(x): # p doesn't not share this object
    ...