在 gevent 中的 fd 上监听 POLLIN

Question

我想将 ZeroMQ 连接到 gevent 循环。使用 ZeroMQ API，我可以获取套接字的 fd。如何在 greenlet 中观察此套接字的 POLLIN 事件，而不阻塞其他 greenlet？

Answer 1

在 github/pypi 上查看 gevent-zeromq

Answer 2

# for gevent >= 1.0
hub = gevent.get_hub()
watcher = hub.loop.io(fd, 1)  # 1 = READ, 2 = WRITE, 3 = READ|WRITE
hub.wait(watcher)
# fd is now ready for reading

然而，最好弄清楚如何使用 gevent-zeromq 来实现此目的或扩展它以支持您的用例。

Answer 3

这是来自 ZeroMQ 的示例。请求-回复代理 http://zguide.zeromq.org/py:rrbroker
它监听 POLLIN 事件，并且使用 gevent-zeromq 不会阻塞其他线程。

这样做你正在寻找什么？