为什么多处理不起作用？

Question

我有这样的代码：

import multiprocessing 


def worker(): 
    print 'Worker' 
    return 

if __name__ == '__main__': 
    jobs = [] 
    for i in range(5): 
     p = multiprocessing.Process(target=worker) 
     jobs.append(p) 
     p.start() 

无论出于何种原因，它打印“工人”两次，然后停止。有谁知道为什么？我究竟做错了什么？

Answer 1

在定义的“核心”值上启动Python中的多处理任务时，最好选择创建一个池并启动该池内的进程。

pool = multiprocessing.Pool() 
for i in range(5): 
    pool.apply_async(worker) 
pool.close() 

但是，如果你喜欢这样做对你的方式，我认为你必须添加p.join()：

import multiprocessing 


def worker(): 
    print 'Worker' 
    return 

if __name__ == '__main__': 
    jobs = [] 
    for i in range(5): 
     p = multiprocessing.Process(target=worker) 
     jobs.append(p) 
     p.start() 
     p.join()