Warum Multiprozessing nicht funktioniert?

Question

Ich habe diesen Code:

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() 

Aus welchem ​​Grund er druckt ‚Arbeitnehmer‘ zwei Mal und stoppt. Weiß jemand warum? Was mache ich falsch?

Answer 1

Starten von Multiprocessing-Aufgaben in Python auf einem definierten Wert von "Kernen", wählen Sie lieber einen Pool zu erstellen und den Prozess innerhalb des Pools zu starten.

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

Aber wenn Sie es auf Ihrem Weg zu tun, ich denke, Sie p.join() hinzufügen:

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()