使用subprocess.Popen调用子进程后stdout为空问题咨询

想要编写代码终止可能陷入停滞、无法响应KeyboardInterrupt的计算任务，采用子进程方案解决，但发现计算正常及时结束时，代码无法返回结果。

现有代码 #

temp2.py #

import os
import signal
import time

# 用于终止subprocess2的超时监控进程
def subprocess1(timeout, subprocess2_pid):
    # 计算最大持续时长的定时器
    time.sleep(timeout)
    
    # 向subprocess2发送终止信号
    os.kill(subprocess2_pid, signal.SIGTERM)

# 包含可能无法被KeyboardInterrupt终止的计算任务
def subprocess2():
    # 此处计算会立即完成
    # 要模拟"卡住"的情况，可以尝试计算999**99999999
    result = 999**9999
    return result

temp.py #

import subprocess
from temp2 import subprocess1, subprocess2

if __name__ == "__main__":
    # 启动subprocess2（计算任务）
    process2 = subprocess.Popen(["python", "-c", "from temp2 import subprocess2; subprocess2()"], stdout=subprocess.PIPE, stderr=subprocess.PIPE)

    # 获取subprocess2的PID
    subprocess2_pid = process2.pid

    # 启动subprocess1（超时监控）
    timeout = 2  # 设置subprocess1的超时时间
    process1 = subprocess.Popen(["python", "-c", f"from temp2 import subprocess1; subprocess1({timeout}, {subprocess2_pid})"])
    
    # 获取stdout和stderr，等待subprocess2完成
    stdout, stderr = process2.communicate()

问题原因 #

stdout为空的核心原因是：subprocess2函数仅通过return返回结果，但没有将结果输出到标准输出（stdout）。父进程通过communicate()读取的是子进程的标准输出内容，而子进程执行subprocess2()后没有任何输出，因此stdout自然为空。

额外补充两点细节：

• Windows系统中signal.SIGTERM的行为和Linux不同，无法像Linux那样可靠终止Python进程，后续可以考虑用process.terminate()替代跨进程的os.kill。
• 额外启动subprocess1作为超时监控进程的方案不够高效，用线程定时器（threading.Timer）可以在父进程内实现超时控制，避免多进程的开销。

解决方案 #

1. 修改subprocess2，将结果输出到stdout #

修改temp2.py中的subprocess2函数，添加print(result)，让结果输出到标准输出：

def subprocess2():
    result = 999**9999
    print(result)  # 将结果打印到stdout，父进程才能捕获
    return result

2. 优化超时监控方案（用线程替代子进程） #

可以去掉subprocess1，在父进程中用threading.Timer实现超时终止，更简洁高效：
修改后的temp.py：

import subprocess
import threading

def terminate_process(process):
    if process.poll() is None:  # 检查进程是否还在运行
        process.terminate()

if __name__ == "__main__":
    # 启动计算子进程
    process2 = subprocess.Popen(
        ["python", "-c", "from temp2 import subprocess2; subprocess2()"],
        stdout=subprocess.PIPE,
        stderr=subprocess.PIPE,
        text=True  # 直接获取字符串而非字节
    )

    # 设置超时定时器：2秒后如果进程还在运行则终止
    timeout = 2
    timer = threading.Timer(timeout, terminate_process, args=(process2,))
    timer.start()

    # 获取输出并等待进程结束
    stdout, stderr = process2.communicate()
    timer.cancel()  # 进程正常结束，取消定时器

    # 处理结果
    if stdout:
        print("计算结果：", stdout.strip())
    if stderr:
        print("错误信息：", stderr.strip())

补充说明 #

• 如果需要传递复杂结果，除了打印到stdout，还可以用序列化（比如json.dumps）后输出，父进程再反解析。
• Windows下如果terminate()无法终止顽固进程，可以尝试process.kill()强制结束。

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