Python的多處理池無法完成

Question

我正在下面（示例）代碼：

from multiprocessing import Pool 

def f(x): 
    return x*x 

pool = Pool(processes=4) 
print pool.map(f, range(10)) 

但是，代碼永遠不會完成。我究竟做錯了什麼？

線

pool = Pool(processes=4) 

成功完成後，它似乎停止在最後一行。甚至沒有按ctrl + c中斷執行。我正在Spyder的ipython控制檯中運行代碼。

Answer 1

由於某種原因，您的構造函數將解釋器拋入線程生產工廠。 您首先需要停止所有正在運行的線程，並且會有噸。如果你調出任務管理器，你會看到大量的流氓python.exe任務。殺死他們批量試：

taskkill /F /IM python.exe 

你需要做上述幾次，確保任務管理器不顯示了任務python.exe。這也會殺死你的spyder實例。所以確保你保存。

現在改變你的代碼如下：

from multiprocessing import Pool 

def f(x): 
    return x*x 

if (__name__ == '__main__'): 
    pool = Pool(4) 
    print pool.map(f, range(10)) 

請注意，我已經刪除了過程命名參數。