Python-Warteschlange Anzahl der unerledigten Aufgaben

Question

Ich implementiere Python Queue mit Thread. Ich brauche einen Weg, um die Gesamtzahl der Elemente in der Warteschlange (die ich mit queue.qsize() bekommen kann) und die Anzahl der unerledigten Aufgaben zu bekommen. Grundsätzlich benötige ich eine Zählung aller Artikel, die bearbeitet werden/bearbeitet werden müssen. Die Python Queue documentation erwähnt folgendes:

Die Zahl der noch nicht abgeschlossenen Aufgaben nach oben geht, wenn ein Element der Warteschlange hinzugefügt wird. Die Anzahl sinkt, wenn ein Consumer-Thread task_done() aufruft, um anzuzeigen, dass das Element abgerufen wurde und alle daran vorgenommenen Aufgaben abgeschlossen sind. Wenn die Anzahl nicht bearbeiteter Aufgaben auf Null fällt, wird durch Join() die Freigabe aufgehoben.

Aber es bietet keinen Einblick wie auf diese Anzahl zugreifen. Danke im Voraus!

Answer 1

Ich bin überrascht, es ist nicht in der Dokumentation erwähnt, aber Queue Objekte haben ein unfinished_tasks Attribut:

>>> x = queue.Queue() 
>>> x.unfinished_tasks 
0 
>>> x.put("test") 
>>> x.unfinished_tasks 
1 

Da es in der Dokumentation nicht erwähnt wird es nicht als Teil der öffentlichen Schnittstelle gewährleistet ist und möglicherweise nicht threadsicher.