Python的多处理map_async在Windows上生成错误

Question

以下代码在Unix上完美工作，但在Windows 7上生成multiprocessing.TimeoutError（两个操作系统都使用python 2.7）。

任何想法为什么？谢谢。

from multiprocessing import Pool 

def increment(x): 
    return x + 1 

def decrement(x): 
    return x - 1 

pool = Pool(processes=2) 
res1 = pool.map_async(increment, range(10)) 
res2 = pool.map_async(decrement, range(10)) 

print res1.get(timeout=1) 
print res2.get(timeout=1) 

Answer 1

你需要把你的实际程序逻辑放在一个if __name__ == '__main__':块中。

在Unixy系统上，Python分叉，生成多个进程以供工作。 Windows没有分叉。 Python必须启动一个新的解释器，然后重新导入所有的模块。这意味着每个子进程将重新导入你的主模块。对于您编写的代码重新导入模块将导致每个新启动的进程启动它自己的进程。

参见：http://docs.python.org/library/multiprocessing.html#windows

编辑这个工作对我来说：

from multiprocessing import Pool 

def increment(x): 
    return x + 1 

def decrement(x): 
    return x - 1 

if __name__ == '__main__': 
    pool = Pool(processes=2) 
    res1 = pool.map_async(increment, range(10)) 
    res2 = pool.map_async(decrement, range(10)) 

    print res1.get(timeout=1) 
    print res2.get(timeout=1)