Python 多进程通信中“管道已关闭”错误：如何解决父子进程通信问题？

“管道已关闭”错误的根源

当使用 python 的 multiprocessing.pipe 建立父子进程通信时，如果一开始就出现“管道已关闭”的错误，通常与管道通信和进程 join 方法的调用有关。

造成错误的原因

问题详情中给出的代码中，子进程在 signal = child_conn.recv() 处进入进程阻塞状态，等待主进程发送信息。但是，直到主进程退出自己的进程，对端关闭连接，子进程还没有收到退出通知，导致自动触发通道内数据的全量读取，而此时通道已关闭。

解决方案

可以通过在 signal = child_conn.recv() 上添加错误捕获来解决此问题，忽略错误。这是因为主进程不发送退出通知就退出自己的进程也是合理的情况。

修改后的代码

在 service.py 中，添加错误捕获：

# catch IOError when main process automatically exit
try:
    signal = child_conn.recv()
    if signal:
        child_conn.close()
except EOFError as err:
    print(err)

其他注意事项

除了错误捕获之外，还可以通过以下方式避免“管道已关闭”错误：

• 仅在需要时调用 server.stop()，因为它将关闭管道并加入子进程。
• 确保主进程在退出前始终发送退出通知到子进程。
• 考虑使用更健壮的通信方法，例如消息队列或远程过程调用 (rpc)。

以上就是Python 多进程通信中“管道已关闭”错误：如何解决父子进程通信问题？的详细内容，更多请关注硕下网其它相关文章！