在 Python 的多处理库中获取队列长度

Question

我有一个 multiprocessing.Manager 对象，其中包含一个 multiprocessing.Queue 来管理我希望一组进程执行的所有工作。我想获取此队列中剩余的元素数量，并且想知道如何执行此操作？

Python 内置的len() 函数不起作用。

Answer 1

如果你说的队列是multiprocessing.Queue，尝试对multiprocessing.Queue对象使用qsize()方法，但要小心：

qsize()

返回队列的大致大小。因为 多线程/多处理语义，这个数字是不可靠的。

请注意，这可能会在 Unix 平台上引发 NotImplementedError，例如 未实现 sem_getvalue() 的 Mac OS X。