Python Pool funktioniert nicht

Question

Ich versuche Multithreading zu verwenden und um es einfach zu halten zuerst, ich bin mit den folgenden Code:

import multiprocessing as mp 

pool = mp.Pool(4) 

def square(x): 

    return x**2 

results=pool.map(square,range(1,20)) 

wie ich sie verstehe, sollten die Ergebnisse eine Liste sein mit den Quadraten von 1 bis 20. Der Code scheint jedoch nicht zu enden. (Das gleiche ohne pool endet im Handumdrehen, das lief für einige Minuten, bevor ich es manuell gestoppt habe).

Weitere Informationen: Task-Manager sagt mir, dass die zusätzlichen Python-Prozesse gestartet wurden und ausgeführt werden, aber verwenden Sie% meiner CPU; noch andere nicht verwandte Prozesse wie Firefox explodieren in ihrer CPU-Nutzung, während das Programm läuft. Ich benutze Windows 8 und eine i5-4300U CPU (Pooling zu 2 statt 4 hilft auch nicht)

Was mache ich falsch? Gibt es gute Ressourcen in der Pool-Klasse, die mir helfen könnten zu verstehen, was mit meinem Code nicht stimmt?

Answer 1

Ihr Code verursacht, dass jeder Prozess auf einen Attributfehler stößt, weil er das square-Attribut nicht finden kann, weil es nicht definiert wurde, als Sie den Pool instanziiert haben. Die Prozesse hängen daher danach. Wenn Sie das Quadrat vor dem Pool definieren, wird das Problem behoben. auch

Siehe:

yet another confusion with multiprocessing error, 'module' object has no attribute 'f'

Answer 2

Code mit Pool Initialisierung sollte innerhalb __name__ == "__main__" als multiprocessing das Modul jedes Mal importiert, ein neues Verfahren zum Laichen.

import multiprocessing as mp 

def square(x): 
    return x**2 

if __name__ == '__main__': 
    pool = mp.Pool(4) 
    results=pool.map(square,range(1,20))