本文详解使用 asyncio 创建子进程后实时读取 stdout 的关键要点，重点解决因输出缓冲导致的 readline 返回空字节串问题，并提供可立即运行的修复方案。
本文详解使用 asyncio 创建子进程后实时读取 stdout 的关键要点，重点解决因输出缓冲导致的 readline 返回空字节串问题，并提供可立即运行的修复方案。
在 asyncio 中通过 create_subprocess_exec 启动子进程并读取其 stdout 是常见需求，但实践中常遇到 readline() 返回空字节串（b''）或协程永久阻塞的问题。根本原因并非 asyncio 机制缺陷，而是子进程的标准输出缓冲行为——Python 默认以行缓冲（line-buffered）或全缓冲（fully buffered）模式运行，尤其当 stdout 不连接到终端（如被重定向至管道时），print() 会缓存输出直至缓冲区满或进程退出，导致父进程无法及时读取。
✅ 正确做法：禁用子进程输出缓冲
最直接有效的解决方案是强制子进程使用无缓冲（unbuffered）模式。对 Python 子进程，只需在命令中添加 -u 标志：
self.cmd = ["python", "-u", "stopwatch.py", "10"]
-u 选项确保 sys.stdout 和 sys.stderr 立即刷新，使每一行 print(start) 都能被父进程即时捕获。
✅ 完整可运行示例
以下是修正后的 RobotManager 类，支持多次启停并持续读取 stdout：
import asyncio
class RobotManager:
def __init__(self):
self.cmd = ["python", "-u", "stopwatch.py", "10"]
self.robot = None
async def start(self):
print("✅ Starting stopwatch subprocess...")
self.robot = await asyncio.create_subprocess_exec(
*self.cmd,
stdout=asyncio.subprocess.PIPE,
stderr=asyncio.subprocess.STDOUT, # 可选：合并 stderr 到 stdout 方便统一处理
)
async def stop(self):
if self.robot is None:
return
print("? Sending SIGKILL to subprocess...")
self.robot.kill()
# 持续读取所有已缓冲/待输出的行（直到 EOF）
while True:
line = await self.robot.stdout.readline()
if not line: # readline() 返回 b'' 表示流已关闭（EOF）
break
print(f"⏱️ Read from stdout: {line.decode().strip()}")
await self.robot.wait() # 等待进程彻底终止
print("✅ Subprocess terminated cleanly.")
self.robot = None
async def main():
robot = RobotManager()
await robot.start()
await asyncio.sleep(3) # 运行约 3 秒
await robot.stop()
await robot.start()
await asyncio.sleep(3)
await robot.stop()
if __name__ == "__main__":
asyncio.run(main())
⚠️ 关键注意事项
- 不要在 start() 中调用 readline()：此时子进程刚启动，尚未输出任何内容，会导致协程无限等待。
- 避免 communicate() 用于交互式场景：communicate() 会等待进程完全退出才返回全部输出，不适用于需中途中断并读取中间结果的场景（如本例的“暂停读秒”）。
- 务必检查 line 是否为空：readline() 在流关闭后返回 b''，应作为循环终止条件，而非忽略。
- 编码处理：stdout.readline() 返回 bytes，需用 .decode() 转为字符串（推荐显式指定 utf-8 编码以提高健壮性）。
- 异常防护建议（生产环境）：添加 try/except 处理 ProcessLookupError 或 BrokenPipeError，并在 stop() 中使用 self.robot.terminate() + self.robot.wait(timeout=5) 实现更优雅的超时终止。
✅ 总结
读取子进程 stdout 的核心在于同步父子进程的 I/O 缓冲策略。启用 -u 是 Python 子进程的黄金实践；配合 await proc.stdout.readline() 循环消费，即可实现低延迟、高可靠的数据流读取。只要缓冲问题解决，asyncio 的子进程通信能力完全胜任实时监控、日志采集、交互式工具集成等典型任务。
