我正在使用Python
Queue
和 Thread
实现,需要一种获取队列中当前项目总数的方式(可以使用queue.qsize()
)和未完成任务的计数方式。基本上,我需要所有正在处理/需要处理的项目数量的计数。 Python Queue documentation提到:
每当向队列添加项时,未完成任务的计数会增加。 每当消费者线程调用task_done()以指示已检索该项并且对其进行的所有工作均已完成时,计数会减少。 当未完成任务的计数下降到零时,join() 就会解除阻塞。
但是它没有提供如何访问该计数的见解。提前致谢!