如何优雅终止Python subprocess启动的含Java、tee的子进程并清理僵尸进程？

问题根源 #

僵尸进程产生的核心原因是子进程退出后，父进程未调用wait()/waitpid()回收其退出状态。在你的场景中：

1. 嵌套bash脚本启动的Java和tee进程，在父bash被终止后会成为孤儿进程，被容器的PID1进程收养。
2. 如果容器的PID1不是init/systemd这类自动处理僵尸进程的进程（比如是你的Python启动进程），就会导致这些孤儿进程退出后残留为僵尸。
3. 管道创建的Java和tee进程可能不在主进程组内，导致os.killpg发送的SIGTERM无法覆盖到它们。

分步解决方案 #

1. 让所有子进程加入同一个进程组并转发终止信号 #

修改run_java_app.sh，添加信号陷阱，确保父bash收到终止信号时能转发给所有子进程：

# run_myapp.sh
arg1=$1
arg2=$2

# 修正笔误：LOG_DIR应为目录，LOG_FILE为具体日志文件
LOG_DIR=/apps/myapp/logs
LOG_FILE=${LOG_DIR}/app.log
JAVA_OPTS="-Xms512m -Xmx4G -Drs.logpath=$LOG_DIR"
EXEC_CMD="java $JAVA_OPTS -cp $CLASSPATH com.myapp.TestApp $arg1 $arg2"

# 添加信号陷阱：收到TERM/INT信号时，终止当前进程组的所有子进程
trap 'kill -TERM 0' TERM INT

exec 3>&1 1>>${LOG_FILE} 2>&1
echo "JAVA_OPTS: $JAVA_OPTS"| tee /dev/fd/3
echo "EXEC_CMD: $EXEC_CMD"| tee /dev/fd/3

# 去掉exec，保留bash作为父进程以触发陷阱；添加wait等待子进程退出
$EXEC_CMD 2>&1 | tee /dev/fd/3
wait

同时修改prep_and_launch.sh，用exec替换当前进程，确保它属于主进程组：

# prep_and_launch.sh
#! /bin/bash
arg1=${1:-"test1"}
arg2=${2:-"100"}

# do some munging, setup, and prep for java run here

# 用exec替换当前bash进程，确保子脚本属于同一个进程组
exec /apps/myapp/scripts/run_java_app.sh $arg1 $arg2

2. 在Python启动进程中处理SIGCHLD，回收僵尸进程 #

如果容器的PID1是你的Python进程，必须添加SIGCHLD信号处理逻辑，主动回收退出的子进程：

import os
import signal
import subprocess

# 处理SIGCHLD信号，回收所有退出的子进程
def handle_sigchld(signum, frame):
    while True:
        try:
            # WNOHANG：非阻塞模式，没有待回收的进程就返回
            pid, status = os.waitpid(-1, os.WNOHANG)
            if pid == 0:
                break
        except OSError:
            # 没有更多子进程需要回收时退出循环
            break

# 注册信号处理函数
signal.signal(signal.SIGCHLD, handle_sigchld)

# 原有的进程启动逻辑
_processes={}
script = '/apps/myapp/prep_and_launch'
process = subprocess.Popen([script, 'test1', "200"], preexec_fn=os.setsid)
_processes[script] = process
ret = process.wait()

3. 优化终止逻辑，确保进程组完全退出 #

修改终止代码，添加超时等待和强制清理：

import os
import signal
import subprocess

process = _processes[script]
pgid = os.getpgid(process.pid)

# 先发送SIGTERM优雅终止
os.killpg(pgid, signal.SIGTERM)

try:
    # 等待主进程退出，超时5秒
    process.wait(timeout=5)
except subprocess.TimeoutExpired:
    # 超时后发送SIGKILL强制终止所有进程组内进程
    os.killpg(pgid, signal.SIGKILL)
    # 等待进程彻底退出
    process.wait()

额外注意事项 #

• 检查容器的PID1：如果你的容器启动命令不是init类进程，而是直接运行Python脚本，必须确保Python处理SIGCHLD。
• 确保LOG_DIR目录存在：Java进程启动前需要保证日志目录已创建，否则可能启动失败。

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