使用Python產生多個進程

Question

早些時候，我嘗試在python中使用線程模塊來創建多個線程。然後我瞭解了GIL以及它如何不允許在一臺機器上利用多個CPU內核。所以現在我試圖做多處理（我不嚴格需要單獨的線程）。

這是我寫的示例代碼，以查看是否正在創建不同的進程。但是從下面的輸出中可以看出，我每次都得到相同的進程ID。所以多個進程沒有被創建。我錯過了什麼？

import multiprocessing as mp 
import os 

def pri(): 
    print(os.getpid()) 

if __name__=='__main__': 

    # Checking number of CPU cores 
    print(mp.cpu_count()) 

    processes=[mp.Process(target=pri()) for x in range(1,4)] 

    for p in processes: 
     p.start() 

    for p in processes: 
     p.join() 

輸出：

4 
12554 
12554 
12554 

Answer 1

的Process類需要一個可調用作爲其目標。

而不是在單獨的進程中運行該函數，而是調用它並將結果（本例中爲None）傳遞到Process類。

只需更改如下：

mp.Process(target=pri()) 

有：

mp.Process(target=pri) 

Answer 2

由於子進程運行在不同的過程中，你不會看到他們的打印報表。他們也不共享相同的內存空間。你傳遞pri（）到目標，它需要pri。您需要通過一個可調用對象，而不是執行它。

您看到的打印件是主線程執行的一部分。因爲您通過pri()，代碼實際上執行。您需要更改代碼，以便pri函數返回值，而不是打印它。

然後，你需要實現一個queue，其中所有的線程寫它和他們做的時候，你的主線程讀取隊列。

multiprocessing模塊的一個很好的功能是Pool對象。它允許你創建一個線程池，然後使用它。這更方便。

我試過了你的代碼，事情是該命令執行得太快，所以操作系統重用了PID。如果您在pri函數中添加time.sleep（1），它將按您的預期工作。

這僅適用於Windows。下面的例子是在Windows平臺上進行的。在Unix上像機器一樣，你不需要睡眠。

更方便的解決方案是這樣的：

from multiprocessing import Pool 
from time import sleep 
import os 

def pri(x): 
    sleep(1) 
    return os.getpid() 

def use_procs(): 
    p_pool = Pool(4) 
    p_results = p_pool.map(pri, [_ for _ in range(1,4)]) 
    p_pool.close() 
    p_pool.join() 
    return p_results 

if __name__ == '__main__': 
    res = use_procs() 
    for r in res: 
     print r 

如果沒有睡眠：

==================== RESTART: C:/Python27/tests/test2.py ==================== 
6576 
6576 
6576 
>>> 

與睡眠：

==================== RESTART: C:/Python27/tests/test2.py ==================== 
10396 
10944 
9000