在多个Python多处理队列上"选择"？

Question

在两个(多处理)队列中的任何一个队列中存在某些东西(两者都驻留在同一系统上)之前,等待(不旋转)的最佳方法是什么？

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,我没有找到任何聪明的方法来做到这一点(我真的很喜欢).

Answer 2

看起来还没有正式的方法来解决这个问题.或者至少,不是基于这个:

• http://bugs.python.org/issue3831

你可以试试这篇文章正在做的事情 - 访问底层管道文件句柄:

• http://haltcondition.net/?p=2319

然后使用select.