如何实时监控子进程的stdout？解决子进程输出缓冲问题

主进程通过管道监控生成图片的子进程，期望捕获到子进程输出'2'或'3'时立即启动处理逻辑，但目前子进程需生成完所有20张图片后才会一次性返回输出，仅调试模式下能实时获取输出。

子进程代码（sub_process.py）：

import time
for i in range(20):
    time.sleep(1)
    print(i)
    # 每秒生成一张图片

主进程代码：

from subprocess import PIPE, Popen

p = Popen(['python', "./sub_process.py"], stdout=PIPE, stderr=PIPE) 

while True:
    line = p.stdout.readline().decode("utf-8")
    if '2' in line:
        print('enough image')
        break
print('go on processing images generated by subprocess.py')

Python的标准输出（stdout）默认会根据输出目标调整缓冲策略：

• 输出到终端时采用行缓冲，每打印一行就刷新输出；
• 输出被重定向到管道（如主进程的PIPE捕获）时，会切换为块缓冲，只有缓冲区填满或进程结束时才会一次性输出内容。

方法1：子进程中强制刷新输出 #

修改子进程的print语句，添加flush=True参数，强制每次打印后立即刷新缓冲区：

import time
for i in range(20):
    time.sleep(1)
    print(i, flush=True)  # 添加flush=True强制刷新
    # 每秒生成一张图片

方法2：启动子进程时启用无缓冲模式 #

启动子进程时给Python解释器加上-u参数，强制标准流使用无缓冲模式：

from subprocess import PIPE, Popen

# 添加-u参数启用无缓冲
p = Popen(['python', "-u", "./sub_process.py"], stdout=PIPE, stderr=PIPE) 

while True:
    line = p.stdout.readline().decode("utf-8")
    # 处理子进程结束的情况，避免死循环
    if not line:
        break
    if '2' in line:
        print('enough image')
        break
print('go on processing images generated by subprocess.py')

方法3：子进程中修改stdout缓冲设置 #

通过sys模块直接修改stdout的缓冲模式，实现实时输出：

import sys
import time

# 设置stdout为行缓冲
sys.stdout.reconfigure(line_buffering=True)

for i in range(20):
    time.sleep(1)
    print(i)
    # 每秒生成一张图片

主进程循环中建议添加子进程结束的判断（如if not line），避免子进程意外退出后主进程陷入死循环。

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