使用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