多处理代码在导入时起作用，在被调用时中断

Question

在一个名为 test.py 的文件中，我有

print 'i am cow'
import multi4
print 'i am cowboy'

在multi4.py 我有

import multiprocessing as mp
manager = mp.Manager()
print manager

我对这段代码的运行方式感到困惑。

在命令行中，如果我输入python，然后在python环境中输入import test.py，我会得到预期的行为：

Python 2.7.3 (default, Apr 10 2012, 23:31:26) [MSC v.1500 32 bit (Intel)] on win32 Type "help", "copyright", "credits" or "license" for more information.

>>>import test
i am cow
<multiprocessing.managers.SyncManager object at 0x025209B0>
i am cowboy 
>>>

但是，如果我在命令行输入test.py，我会得到

i am cow
i am cow
i am cow
i am cow
i am cow
i am cow
i am cow
i am cow
i am cow
i am cow
i am cow
i am cow
i am cow
i am cow
i am cow
i am cow
i am cow
i am cow

除非我杀了它，否则这大概会永远持续下去。当我杀死它时，我得到了一堆重复的错误：

KeyboardInterrupt
Traceback (most recent call last):
  File "<string>", line 1, in <module>
  File "C:\Python27\lib\multiprocessing\forking.py", line 373, in main
    prepare(preparation_data)
  File "C:\Python27\lib\multiprocessing\forking.py", line 488, in prepare
    '__parents_main__', file, path_name, etc
KeyboardInterrupt
Traceback (most recent call last):
  File "<string>", line 1, in <module>
  File "C:\Python27\lib\multiprocessing\forking.py", line 373, in main
    prepare(preparation_data)
  File "C:\Python27\lib\multiprocessing\forking.py", line 488, in prepare
    '__parents_main__', file, path_name, etc
KeyboardInterrupt

那么发生了什么？为什么它在导入时以一种方式运行，而当我尝试运行它时又以另一种方式运行？

Answer 1

multiprocessing won't work properly 在 Windows 上的交互式提示中，因为它无法在它产生的子进程中正确重新导入 __main__。然而，这实际上帮助你，因为它可以防止manager = mp.Manager() 行在Manager 启动时产生的子进程中递归执行。

然而，在实际脚本中，孩子可以正确地重新导入__main__。您看到了无限递归，因为您没有使用 if __name__ == "__main__": 保护来保护对 mp.Manager() 的调用，即 required on Windows 以防止在重新导入发生时在子级中执行 mp.Manager()：

import multiprocessing as mp
if __name__ == "__main__":
    manager = mp.Manager()
    print manager

编辑：

您的示例，您的主脚本 (test.py) 导入创建 Manager 的模块，需要进行一些重构。您需要通过调用模块中实际使用multiprocessing 的方法，从主脚本中实例化Manager：

print 'i am cow'
import multi4
if __name__ == "__main__":
    multi4.init_manager()
print 'i am cowboy'

multi4.py

import multiprocessing as mp
manager = None
def init_manager():
    global manager
    manager = mp.Manager()

这是确保仅在实际执行脚本时才创建 Manager 的唯一方法。