Python多进程中判断管道是否为空，poll始终返回False的问题

先解决poll()始终返回False的问题 #

出现这个问题的常见原因有三个：

1. 进程未正确启动：你代码里的p4.start缺少括号，必须写p4.start()才会启动子进程，否则Show_image函数根本不会执行。
2. 管道端点搞反：确保发送数据时用的是pre_in_1/pre_in_2，接收端用pre_out_1/pre_out_2。如果搞反成用pre_out_1.send()发送，接收端永远收不到数据。
3. 单向管道配置错误：如果创建管道时指定了duplex=False，那么pre_out_1只能接收、pre_in_1只能发送，绝对不能混用。

实现「任一管道有数据就立即显示」的最优方案 #

不推荐用轮询poll()的方式，效率低且代码冗余。推荐用multiprocessing.connection.wait()，它可以同时监听多个管道，直接返回就绪的连接列表，完美匹配你的需求。

完整可运行代码示例 #

import multiprocessing
from multiprocessing import Pipe, Process
import time
import cv2
import numpy as np

# 模拟向管道发送图像的子进程
def send_image_task(pipe_in, send_interval):
    for i in range(8):
        # 生成测试图像，替换成你的实际图像生成/读取逻辑
        test_img = np.zeros((400, 600, 3), dtype=np.uint8)
        cv2.putText(test_img, f"Pipe {pipe_in} - Img {i+1}", (30, 50), 
                    cv2.FONT_HERSHEY_SIMPLEX, 1, (0,255,0), 2)
        pipe_in.send(test_img)
        time.sleep(send_interval)
    pipe_in.close()

def Show_image(pre_out_1, pre_out_2):
    while True:
        # 监听两个管道，无超时等待，直到任一管道有数据
        ready_conns = multiprocessing.connection.wait([pre_out_1, pre_out_2])
        for conn in ready_conns:
            try:
                img = conn.recv()
                # 显示图像，替换成你的图像显示逻辑
                cv2.imshow("Real-time Image", img)
                # 处理窗口事件，避免卡死，按q退出
                if cv2.waitKey(1) & 0xFF == ord('q'):
                    cv2.destroyAllWindows()
                    return
            except EOFError:
                # 管道被发送端关闭时，退出循环
                cv2.destroyAllWindows()
                return

if __name__ == "__main__":
    # 创建双向管道
    pre_out_1, pre_in_1 = Pipe()
    pre_out_2, pre_in_2 = Pipe()

    # 启动两个模拟发送图像的进程（不同发送频率）
    p1 = Process(target=send_image_task, args=(pre_in_1, 1))
    p2 = Process(target=send_image_task, args=(pre_in_2, 2.5))
    p1.start()
    p2.start()

    # 启动显示进程（注意start()带括号）
    p4 = Process(target=Show_image, args=(pre_out_1, pre_out_2))
    p4.start()

    # 等待子进程结束
    p1.join()
    p2.join()
    p4.join()

关键说明 #

• multiprocessing.connection.wait()会阻塞直到监听的管道中有数据就绪，直接返回可用连接，无需手动轮询。
• 捕获EOFError是为了处理发送端关闭管道的情况，避免无限阻塞。
• 显示图像时必须调用cv2.waitKey(1)（如果用OpenCV），否则窗口会无响应，其他显示库同理需要处理窗口事件。

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