Python subprocess多轮I/O交互：维持子进程运行及解决挂起问题

当然可以保持子进程打开来进行多次I/O交互！subprocess.communicate()确实会一次性发送所有输入、等待进程结束并关闭管道，这就是它没法支持多轮交互的原因。你的代码出现挂起，大概率是因为管道缓冲没处理好，或者输入输出的同步逻辑有问题。

下面我给你一套可行的解决方案，附完整代码示例：

核心思路 #

1. 启动子进程时正确配置管道参数，禁用缓冲避免输出滞留
2. 手动通过stdin.write()和stdout.readline()进行多轮读写，每次操作后强制刷新缓冲区
3. 设计明确的退出信号，让子进程可以主动终止，避免僵尸进程

父进程代码 #

from __future__ import print_function
import subprocess
import sys

# 启动子进程：-u参数禁用Python的标准IO缓冲，text=True用文本模式处理数据
p = subprocess.Popen(
    [sys.executable, '-u', 'child_process.py'],
    stdin=subprocess.PIPE,
    stdout=subprocess.PIPE,
    stderr=subprocess.PIPE,
    text=True
)

# 第一轮交互
p.stdin.write("Hello from parent!\n")
p.stdin.flush()  # 必须刷新缓冲区，否则输入可能留在本地不发送
response = p.stdout.readline().strip()
print(f"Parent received: {response}")

# 第二轮交互
p.stdin.write("What's your name?\n")
p.stdin.flush()
response = p.stdout.readline().strip()
print(f"Parent received: {response}")

# 发送退出信号，结束交互
p.stdin.write("exit\n")
p.stdin.flush()

# 等待子进程结束，获取剩余输出和错误信息
final_stdout, stderr = p.communicate()
print(f"Final output: {final_stdout.strip()}")
if stderr:
    print(f"Error log: {stderr.strip()}")

子进程代码（命名为child_process.py） #

from __future__ import print_function
import sys

while True:
    # 读取父进程的输入行
    input_line = sys.stdin.readline()
    if not input_line:
        # 父进程关闭stdin时退出循环
        break
    
    input_content = input_line.strip()
    if input_content == "exit":
        print("Child: Goodbye!")
        sys.stdout.flush()
        break
    
    # 生成响应并发送给父进程
    print(f"Child received: '{input_content}'")
    sys.stdout.flush()  # 同样要刷新，确保输出立即发送到管道

关键注意事项 #

• 禁用缓冲：子进程必须加-u参数，否则Python会把输出攒到一定量才发送，导致父进程一直等待输出挂起
• 强制刷新：每次stdin.write()和sys.stdout.print()后都要调用flush()，确保数据立即通过管道传输
• 行读取匹配：用readline()读取子进程的输出（对应子进程的print()换行），不要用read()——后者会一直等待EOF，而子进程还在运行时永远不会触发EOF，直接导致挂起
• 错误处理：不要忽略stderr，如果子进程有错误输出没被读取，缓冲区满了也会导致进程阻塞

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