python - 多处理管理器的 EOFError

Question

我有一堆客户端通过 0MQ 连接到服务器。我有一个管理器队列，用于工作池与每台客户端计算机上的主进程进行通信。

在一台有 250 个工作进程的客户端机器上，我几乎立即看到一堆 EOFError。它们发生在执行 put() 时。

我希望大量的通信可能会减慢一切，但我永远不会在内部多处理逻辑中看到 EOFError。我没有使用 gevent 或任何可能破坏标准套接字功能的东西。

有什么想法可以让管理器队列开始引发 EOFError 吗？

Answer 1

对我而言，错误实际上是我的接收进程抛出异常并终止，因此发送进程收到 EOFError，这意味着进程间通信管道已关闭。