Python2.7+Ubuntu14.04中subprocess僵尸进程与communicate()挂起问题

云原生阿岚

2026-5-29

问题分析与解决方案

子进程为何会变为僵尸进程？

僵尸进程的本质是子进程已经终止，但父进程尚未回收它的退出状态信息。当子进程接收到SIGINT信号终止后，内核会释放它的内存、打开文件等资源，但会保留进程描述符（包含PID、退出状态等关键信息），直到父进程通过wait()或waitpid()系统调用读取这些数据。如果父进程一直未执行回收操作，子进程就会以<defunct>状态留在进程列表中，也就是我们看到的僵尸进程。

在你的代码场景里，虽然最终调用了communicate()，但它提前挂起，导致父进程没能及时完成对子进程的回收，所以子进程先变成了僵尸。

父进程为何在`communicate()`处挂起？

subprocess.Popen.communicate()的工作流程是：

持续读取子进程的stdout和stderr，直到管道遇到EOF；
等待子进程完全终止（内部会调用waitpid()）；
返回读取到的输出内容。

挂起的核心原因是父进程仍在等待子进程的输出管道关闭。当你给子进程发送SIGINT后，可能出现两种情况：

子进程的输出缓冲区还有数据没来得及刷新到管道，或者子进程的信号处理逻辑没有正确终止进程、关闭文件描述符；
即使子进程变成僵尸，只要管道的写端未被内核关闭，父进程就会一直阻塞在读取管道的步骤，导致communicate()无法继续执行。

如何让父进程可靠处理避免挂起？

针对Python 2.7和Ubuntu 14.04的环境，推荐下面几种可行方案：

方案1：主动检查子进程状态，手动控制超时

在发送SIGINT后，先通过poll()轮询子进程是否终止，再调用communicate()；如果超时还未终止，就强制杀掉子进程。这样能避免无限挂起：

import subprocess
import signal
import time

# 替换成你的实际命令
cmd = ["echo", "test", "&&", "sleep", "10"]
bag_process = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE)

for i in range(5):
    print "Countdown: {}".format(5 - i - 1)
    time.sleep(1)

print "Sending SIGINT to PID {}".format(bag_process.pid)
bag_process.send_signal(signal.SIGINT)

# 手动模拟超时（Python 2.7的communicate无timeout参数）
timeout = 3
start_time = time.time()
retcode = None
bag_out, bag_err = "", ""

while time.time() - start_time < timeout:
    retcode = bag_process.poll()
    if retcode is not None:
        # 子进程已终止，读取剩余输出
        bag_out, bag_err = bag_process.communicate()
        break
    time.sleep(0.2)
else:
    # 超时未终止，强制杀死子进程
    print "子进程超时，强制终止"
    bag_process.kill()
    bag_out, bag_err = bag_process.communicate()

print "子进程退出码:", retcode
print "标准输出:\n", bag_out
print "标准错误:\n", bag_err

方案2：让子进程正确处理SIGINT信号

如果子进程是你自己开发的代码，可以在子进程中添加SIGINT信号处理逻辑，确保退出时刷新并关闭所有输出流：

# 子进程示例代码
import signal
import sys
import time

def handle_sigint(signum, frame):
    # 强制刷新输出缓冲区，避免数据滞留
    sys.stdout.flush()
    sys.stderr.flush()
    # 正常退出
    sys.exit(0)

# 注册SIGINT信号处理器
signal.signal(signal.SIGINT, handle_sigint)

# 子进程业务逻辑示例
while True:
    print "子进程正在运行..."
    time.sleep(1)

方案3：通过preexec_fn配置子进程信号行为（慎用）

在启动子进程时，使用preexec_fn参数让子进程重置SIGINT的处理方式，确保收到信号后能正常终止。注意：这个方法仅适用于Unix系统，且要避免在多线程环境中使用：

import subprocess
import signal
import time

def reset_sigint():
    # 让子进程使用默认的SIGINT处理逻辑（终止进程）
    signal.signal(signal.SIGINT, signal.SIG_DFL)

cmd = ["your_command_here"]
bag_process = subprocess.Popen(
    cmd,
    stdout=subprocess.PIPE,
    stderr=subprocess.PIPE,
    preexec_fn=reset_sigint
)

# 后续代码和之前一致...

内容的提问来源于stack exchange，提问作者Edward Ned Harvey