Python MultiProcessing.Pool: Wie ohne iterable zu benutzen?

Question

Multi-Threaded-Prozesse

p = ThreadPool(processes=10) # creates a pool of 10 workers 
    p.map(function_to_call, iterable) # calls FUNCTION_TO_CALL with the first item from iterable as parameter 
    p.close() # closes the multi-threaded processes one all threads done 

Ich habe versucht, dieses Modell zu verwenden, aber was ist, wenn ich eine Funktion einfädeln wollen, die keine Parameter hat. Wie run(). Was würde ich legte für den ‚iterable‘ Raum, ich habe alle um gesucht und kann eine Lösung nicht finden.

Answer 1

Die Pool.apply Funktion ist, was Sie suchen. Verwenden Sie Pool.apply_async wenn Sie einen nicht blockierenden Aufruf möchten.

p = ThreadPool(processes=10) 
p.apply(function_to_call) 
p.close()