Tastaturunterbrechungen in Multiprocessing -Pools mit Python

Die Handhabung von KeyboarTinrups ist für die Verwaltung paralleler Prozesse effektiv. Die Multiprocessing -Bibliothek bietet eine Möglichkeit, einen Pool von Arbeitsprozessen zu erstellen, mit denen Aufgaben gleichzeitig ausgeführt werden können. Es entsteht jedoch ein Problem, wenn während der Ausführung dieser Prozesse ein Tastaturinterrupt initiiert wird. Der entsprechende Code innerhalb des außer Blocks wird jedoch niemals ausgeführt, so dass das Programm hängen bleibt.

versuchen: Ergebnisse = Pool.Map (langsam_Square, Bereich (40)) Außer Tastaturinterruhrter: pool.terate () print ("Sie haben das Programm storniert!") sys.exit (1)

cause:

try:
    results = pool.map(slowly_square, range(40))
except KeyboardInterrupt:
    pool.terminate()
    print("You cancelled the program!")
    sys.exit(1)

Lösung:

, um dieses Problem zu lösen, um eine Zeitüberschreitung zu spezifizieren, wenn sie auf die Ergebnisse warten. Dies kann erreicht werden, indem der MAP () -Rall durch map_async () ersetzt wird. Get (Timeout), wobei Timeout auf einen großen Wert eingestellt ist. Keyboarderrupt wurde nicht verarbeitet. Dies ermöglicht dem Ausnahme des Blocks auszuführen, und ermöglicht die Beendigung des Pools und den anmutigen Umgang mit dem Interrupt.