Linux下如何非阻塞检查multiprocessing Pipe是否关闭？

太懂这种查遍Python multiprocessing文档、写过N个测试程序、搜遍谷歌和Stack Overflow却摸不着头绪的憋屈感了！针对你要在Linux下非阻塞检查Pipe另一端是否关闭（哪怕管道里没数据）的需求，其实可以绕开multiprocessing自带的方法，直接利用Linux系统级的IO特性来实现，下面给你两个靠谱的方案：

方案1：通过非阻塞IO结合异常判断 #

multiprocessing的Connection对象其实封装了底层的文件描述符，咱们可以把这个fd设置为非阻塞模式，然后尝试读取一个极小的数据块，通过抛出的异常来判断状态：

import multiprocessing
import fcntl
import os

def is_pipe_closed(conn):
    fd = conn.fileno()
    # 先获取当前的文件状态标志，再添加非阻塞属性
    current_flags = fcntl.fcntl(fd, fcntl.F_GETFL)
    fcntl.fcntl(fd, fcntl.F_SETFL, current_flags | os.O_NONBLOCK)
    
    try:
        # 尝试读取1字节，哪怕没数据也没关系
        tiny_data = conn.recv_bytes(1)
        # 把读出来的字节塞回缓冲区，不影响后续正常接收
        conn._buffer = tiny_data + conn._buffer
        return False  # 管道还活着
    except EOFError:
        # 抛出EOFError说明另一端已经关闭
        return True
    except BlockingIOError:
        # 抛出这个异常说明管道没数据，但另一端还开着
        return False

⚠️ 小提醒：_buffer是Connection的内部属性，在CPython中是稳定的，但如果追求极端兼容性，你也可以自己维护一个缓冲区来暂存读取到的字节。

方案2：用select.poll检测管道挂起事件 #

另一种更“干净”的方法是用Linux的select.poll来检测文件描述符的POLLHUP事件——这个事件专门用来标识“管道另一端已关闭”，而且完全不需要读取数据，也不会修改管道的阻塞状态：

import multiprocessing
import select

def is_pipe_closed(conn):
    poller = select.poll()
    fd = conn.fileno()
    # 注册检测POLLHUP（挂起）事件
    poller.register(fd, select.POLLHUP)
    # 超时设为0，实现非阻塞检查
    events = poller.poll(0)
    poller.unregister(fd)
    
    # 遍历事件，判断是否触发了POLLHUP
    for _, event in events:
        if event & select.POLLHUP:
            return True
    return False

这个方案的优势是完全不干扰管道的正常读写逻辑，只做状态检测，非常适合你的场景——毕竟你还有其他处理任务，不能被阻塞拖慢。

关键注意点 #

• 这两个方案仅适用于Linux，Windows的管道机制和Linux完全不同，你已经研究过Windows的情况，这里就不多赘述了。
• 如果你的管道是双向的（既读又写），要注意区分是哪一端关闭了，不过一般来说，只要任意一端关闭，POLLHUP或者EOFError都会触发。
• 不要在同一个Connection对象上混用阻塞和非阻塞操作，避免出现状态混乱。

内容的提问来源于stack exchange，提问作者QA Collective