所有示例parallel.futures代码均因“ BrokenProcessPool”而失败

Question

在创建所需的实际应用程序之前，我试图对此有一个基本的了解。我最近从2.7移到了3.3。

从python文档直接复制粘贴此代码失败，这里的一个简单示例也是如此。

这是我的代码，从第二个示例派生而来：

import concurrent.futures

nums = [1,2,3,4,5,6,7,8,9,10]

def f(x):
    return x * x

# Make sure the map and function are working
print([val for val in map(f, nums)])

# Test to make sure concurrent map is working
with concurrent.futures.ProcessPoolExecutor() as executor:
    for item in executor.map(f, nums):
        print(item)

这是输出：

[1, 4, 9, 16, 25, 36, 49, 64, 81, 100]
Traceback (most recent call last):
  File "<string>", line 420, in run_nodebug
  File "<module1>", line 13, in <module>
  File "C:\Python33\lib\concurrent\futures\_base.py", line 546, in result_iterator
    yield future.result()
  File "C:\Python33\lib\concurrent\futures\_base.py", line 399, in result
    return self.__get_result()
  File "C:\Python33\lib\concurrent\futures\_base.py", line 351, in __get_result
    raise self._exception
concurrent.futures.process.BrokenProcessPool: A process in the process pool was terminated abruptly while the future was running or pending.

如何使此代码按预期工作？我希望这些示例可以立即使用。

Answer 1

这是我的错，有两个原因：

1. 该代码不受保护，即没有 if __name__
2. 看起来奇怪的Traceback是因为未保存文件。以前从没给我造成任何问题，但是在这种情况下确实没有。

同时纠正 这两个 错误。

最终测试代码：

import concurrent.futures

nums = [1,2,3,4,5,6,7,8,9,10]

def f(x):
    return x * x
def main():
    # Make sure the map and function are working
    print([val for val in map(f, nums)])

    # Test to make sure concurrent map is working
    with concurrent.futures.ProcessPoolExecutor() as executor:
        print([val for val in executor.map(f, nums)])

if __name__ == '__main__':
    main()

预期输出：

[1, 4, 9, 16, 25, 36, 49, 64, 81, 100]
[1, 4, 9, 16, 25, 36, 49, 64, 81, 100]