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)