Python os.fork多进程场景下为何仅部分管道可正常通信？

两个版本的代码踩了os.fork()和管道机制的三个致命错误，故障表现和代码执行顺序直接相关：

• 管道创建时机完全错误
  代码第一行就调用os.fork()，之后才创建三个管道。fork()执行后父子进程是完全独立的地址空间，后续父进程创建的管道、第一个子进程（pid==0的Child1）自行创建的管道是完全独立、互不连通的文件描述符，从根上就没打通通信链路。
• 文件描述符（fd）泄漏
  fork()会把当前进程所有打开的fd完整拷贝给子进程。管道的读端只要检测到任意一个进程还持有该管道的写端fd，调用read()就会永久阻塞等待数据，不会返回EOF。代码里所有进程都没有及时关闭自己用不到的管道端，要么读操作卡住，要么写入的数据无法被正常接收。
• 多余fd关闭时机不对
  代码要么是fork完孙进程之后才关闭多余fd，导致孙进程也持有不该持有的管道端；要么是写完数据不关闭写端，读端会一直等待新数据。

各版本故障具体原因 #

1. 第一版代码：父进程写入Pipe1的数据无法读取
   Child1 fork孙进程之后，没有第一时间在孙进程里关闭Pipe1的写端w，孙进程一直持有这个写fd，导致Child1调用r.read()时内核判定还有写入可能，永久阻塞，因此Pipe1的内容始终无法打印。
2. 第二版代码：Pipe3失效、Child1异常卡住
   把关fd、读Pipe1的逻辑挪到Child1的判断分支后，孙进程依然持有Pipe1的写端，Child1读Pipe1还是会阻塞。同时父进程、Child2、孙进程都持有Pipe3的写端w3，孙进程读r3时，因为其他进程没关闭w3，也会触发阻塞；Child1写完Pipe3之后也没关闭自己持有的w3，进一步加剧阻塞，最终表现为管道失效、进程无响应。

实现多进程管道通信必须严格遵守三个原则：

• 所有管道在fork所有需要使用它的进程之前创建
• 每个进程启动后第一时间关闭自己用不到的所有管道端
• 写完数据立即关闭写端，通知读端数据发送完毕

可正常运行的代码如下：

import os

# 第一步：先创建所有需要的管道，再执行fork
# 管道1：父进程写 -> Child1 读
r1, w1 = os.pipe()
# 管道2：父进程写 -> Child2 读
r2, w2 = os.pipe()
# 管道3：Child1 写 -> 孙进程 读
r3, w3 = os.pipe()

# 先fork第一个子进程Child1
pid1 = os.fork()

if pid1 == 0:
    # Child1 进程逻辑
    # 先关闭所有自己用不到的fd：管道1写端、管道2全端、管道3读端
    os.close(w1)
    os.close(r2)
    os.close(w2)
    os.close(r3)

    # 再fork孙进程
    pid_grand = os.fork()
    if pid_grand == 0:
        # 孙进程逻辑
        # 关闭孙进程不用的fd：管道1读端、管道3写端
        os.close(r1)
        os.close(w3)
        print("孙进程启动")
        # 读取管道3数据
        r3_fd = os.fdopen(r3, 'rb')
        print(f"孙进程收到Child1数据：{r3_fd.read().decode()}")
        r3_fd.close()
        os._exit(0)
    
    # Child1 读取父进程发来的管道1数据
    r1_fd = os.fdopen(r1, 'rb')
    print(f"Child1收到父进程数据：{r1_fd.read().decode()}")
    r1_fd.close()

    # 向孙进程写管道3数据，写完立刻关写端
    print("Child1启动")
    w3_fd = os.fdopen(w3, 'wb')
    w3_fd.write(b"Pipe3: data from Child1")
    w3_fd.close()

    # 回收孙进程资源
    os.waitpid(pid_grand, 0)
    os._exit(0)

# 父进程继续执行，fork第二个子进程Child2
pid2 = os.fork()
if pid2 == 0:
    # Child2 进程逻辑
    # 关闭所有不用的fd：管道1全端、管道2写端、管道3全端
    os.close(r1)
    os.close(w1)
    os.close(w2)
    os.close(r3)
    os.close(w3)

    print("Child2启动")
    # 读取管道2的父进程数据
    r2_fd = os.fdopen(r2, 'rb')
    print(f"Child2收到父进程数据：{r2_fd.read().decode()}")
    r2_fd.close()
    os._exit(0)

# 父进程逻辑
# 关闭所有不用的fd：两个管道的读端、管道3全端（管道3是Child1和孙进程通信使用）
os.close(r1)
os.close(r2)
os.close(r3)
os.close(w3)

print("父进程启动")
# 向两个子进程写数据，写完立刻关闭对应写端
w1_fd = os.fdopen(w1, 'wb')
w1_fd.write(b"Pipe1: data from parent to Child1")
w1_fd.close()

w2_fd = os.fdopen(w2, 'wb')
w2_fd.write(b"Pipe2: data from parent to Child2")
w2_fd.close()

# 回收两个子进程资源，避免僵尸进程
os.waitpid(pid1, 0)
os.waitpid(pid2, 0)
print("所有进程执行完毕")

运行后输出如下，三个管道全部正常通信：

父进程启动
Child2启动
Child2收到父进程数据：Pipe2: data from parent to Child2
Child1收到父进程数据：Pipe1: data from parent to Child1
Child1启动
孙进程启动
孙进程收到Child1数据：Pipe3: data from Child1
所有进程执行完毕

补充注意点：

• 所有子进程逻辑执行完之后用os._exit(0)直接退出，不要走Python默认的退出流程，避免重复执行父进程的资源释放逻辑引发报错。
• 父进程需要调用waitpid回收子进程资源，避免产生僵尸进程。

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