EOFError与多处理管理器

Dus*_*rea 5 python multiprocessing

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

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

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

关于可以放入Manager队列的内容的任何想法都会引发EOFError?

NHD*_*aly 5

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