使用os.pipe()与os.fork()实现Python管道时出现错误求助

你的代码在第二次迭代失败主要有几个核心问题：

1. 重复使用已失效的管道 #

管道是一次性的通信通道，第一次迭代后，子进程关闭了读端，父进程关闭了写端，原管道的文件描述符已经失效，无法在第二次迭代中复用。必须为每次循环创建新的管道。

2. 用文件对象覆盖文件描述符变量 #

第一次迭代中，父进程将r（原本是整数类型的文件描述符）替换成了TextIOWrapper对象。第二次迭代时，子进程尝试对这个对象调用os.close()，自然会抛出类型错误。

3. 重复关闭已失效的文件描述符 #

父进程在第一次迭代中已经关闭了w，第二次迭代再次调用os.close(w)时，该描述符已经无效，导致"Bad file descriptor"错误。

4. 未正确关闭文件对象 #

使用fdopen创建的文件对象如果不手动关闭，会导致底层文件描述符泄漏，引发意外问题。

修复后的代码 #

import os
import sys

def processMain():
    number = 0

    for _ in range(2):
        # 为每次迭代创建新的管道
        r, w = os.pipe()
        pid = os.fork()
        
        if pid == 0:
            # 子进程：关闭不需要的读端，写入加1后的数值
            os.close(r)
            current_num = int(number) + 1
            with os.fdopen(w, "w") as f:
                f.write(str(current_num))
            print("write")
            sys.exit(0)
        
        else:
            # 父进程：等待子进程完成，关闭不需要的写端，读取结果
            os.wait()
            os.close(w)
            with os.fdopen(r) as f:
                number = f.read()
            print("read")
    
    print(number)

processMain()

关键修复点说明 #

• 每次循环新建管道：确保每次父进程和子进程都使用全新的、有效的通信管道。
• 使用with语句管理文件对象：自动关闭文件对象，避免描述符泄漏，同时保证写入的数据被正确刷新。
• 不覆盖原始文件描述符变量：保留r和w的整数类型，确保os.close()调用有效。
• 及时关闭未使用的管道端：子进程关闭读端，父进程关闭写端，符合管道通信的最佳实践，避免资源浪费。

执行修复后的代码，会得到预期输出：

write
read
write
read
2

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