Wie können Daten in Python-Multiprozessen oder Multithreads effizient synchronisiert werden?

Question

Wenn Sie Multi-Threads/Multi-Prozesse verwenden, erhalten Sie Aufgaben einfach über Warteschlangen und dergleichen. Wenn die Aufgabe jedoch abgeschlossen ist, muss ein Wert akkumuliert werden, um die Anzahl der abgeschlossenen Aufgaben zu zählen. In der aktuellen Multi-Thread-/Multi-Prozess-Situation. Ich verwende Thread-Sperre/Prozessmanager + Prozesssperre, um das Synchronisationsproblem der Zählung zu lösen.
Aber es fühlt sich zu ineffizient an. Nicht elegant genug.

Gibt es einen besseren Weg, damit umzugehen?

Ich finde, diese Frage sollte oft gestellt werden. Perfekte Lösungen sollten bereits vorhanden sein.

Ich habe es einfach noch nicht bemerkt.

Answer 1

进程间通信的问题，可以用你喜欢的（熟悉的、可以用的）方式来解决。
下面提供一种方式：

zmq 的 pushpull 模式
http://learning-0mq-with-pyzm...