python - 多个 Python 多处理队列上的 "select"？

Question

什么是等待(不旋转)直到两个(多处理)之一可用的最佳方法Queues ，两者都驻留在同一个系统上？

Answer 1

其实你可以在 select.select 中使用 multiprocessing.Queue 对象。即

que = multiprocessing.Queue()
(input,[],[]) = select.select([que._reader],[],[])

只有当 que 准备好被读取时才会选择它。

虽然没有关于它的文档。我正在阅读 multiprocessing.queue 库的源代码(在 linux 上，它通常类似于/usr/lib/python2.6/multiprocessing/queue.py)来找出它。

对于 Queue.Queue，我没有找到任何聪明的方法来做到这一点(我真的很想这样做)。