本文介绍在 Go 中安全、可靠地实现进程及其整个子进程树（含孙子进程等）的超时终止，核心是利用 Unix 进程组（process group）机制配合 syscall.Kill(-pgid, sig)，并规避常见陷阱（如信号传播失效、goroutine 泄漏、缓冲区缺失等）。
本文介绍在 go 中安全、可靠地实现进程及其整个子进程树（含孙子进程等）的超时终止，核心是利用 unix 进程组（process group）机制配合 `syscall.kill(-pgid, sig)`，并规避常见陷阱（如信号传播失效、goroutine 泄漏、缓冲区缺失等）。
在 Go 中调用外部命令（如 exec.Command）时，若主进程派生了多个子进程（例如 shell 脚本启动了 grep、awk、curl 等），仅调用 cmd.Process.Kill() 仅会终止直接子进程（即 cmd 启动的主进程），而其后代进程（children / grandchildren）可能继续运行，导致资源泄漏或逻辑异常。根本解法是启用 进程组（Process Group），将主进程及其所有后代纳入同一组，再向该组发送信号实现“一键清理”。
✅ 正确做法：启用进程组 + 组信号终止
关键步骤如下：
- 启用进程组：通过 cmd.SysProcAttr = &syscall.SysProcAttr{Setpgid: true} 强制为新进程创建独立进程组（Linux/macOS 下有效）；
- 获取组 ID：使用 syscall.Getpgid(cmd.Process.Pid) 获取该组的 PGID（注意：不是 cmd.Process.Pid 本身，而是其所属的组 ID）；
- 向整个组发信号：调用 syscall.Kill(-pgid, syscall.SIGTERM)（推荐先发 SIGTERM，优雅退出）或 syscall.SIGKILL（强制终止）；
- 避免 goroutine 阻塞：cmd.Wait() 必须在 goroutine 中异步执行，且 done channel 必须为带缓冲 channel（如 make(chan error, 1)），防止超时返回后 goroutine 永久挂起。
以下是完整、健壮的示例代码：
package main
import (
"fmt"
"os/exec"
"syscall"
"time"
)
func runWithTimeout(command string, args []string, timeout time.Duration) error {
cmd := exec.Command(command, args...)
// ✅ 关键：启用进程组，确保子进程继承同一 PGID
cmd.SysProcAttr = &syscall.SysProcAttr{
Setpgid: true, // 创建新进程组，PID 即为 PGID
}
if err := cmd.Start(); err != nil {
return fmt.Errorf("failed to start command: %w", err)
}
done := make(chan error, 1) // ⚠️ 缓冲大小为 1，防 goroutine 泄漏
go func() {
done <- cmd.Wait()
}()
select {
case err := <-done:
return err // 成功完成或出错退出
case <-time.After(timeout):
// 获取进程组 ID（非 cmd.Process.Pid！）
pgid, err := syscall.Getpgid(cmd.Process.Pid)
if err != nil {
return fmt.Errorf("failed to get process group ID: %w", err)
}
// ✅ 向整个进程组发送 SIGTERM（可替换为 syscall.SIGKILL）
if err := syscall.Kill(-pgid, syscall.SIGTERM); err != nil {
return fmt.Errorf("failed to kill process group %d: %w", pgid, err)
}
// 可选：等待几毫秒后强制清理（防止僵死）
select {
case <-time.After(100 * time.Millisecond):
syscall.Kill(-pgid, syscall.SIGKILL) // 最终兜底
case <-done:
return fmt.Errorf("timeout but command finished late")
}
return fmt.Errorf("command timed out after %v", timeout)
}
}
// 使用示例：
// err := runWithTimeout("sh", []string{"-c", "sleep 5; echo done"}, 2*time.Second)⚠️ 注意事项与最佳实践
- 仅限 Unix-like 系统：Setpgid 和负 PID 的 Kill 是 POSIX 行为，在 Windows 上不适用（需改用 os.Process.Kill() + os.Process.Release() 等替代方案）；
- 信号选择建议：优先使用 syscall.SIGTERM（允许进程清理资源），超时未退出再补 SIGKILL；
- Shell 包装陷阱：若命令形如 sh -c "cmd1 | cmd2"，默认 sh 会作为会话首进程（session leader），可能影响组行为——建议显式添加 Setctty: false 和 Noctty: true 增强兼容性；
- 错误处理不可省略：Getpgid 和 Kill 均可能失败（如进程已退出、权限不足），需检查返回值；
- 测试验证：可通过 ps -o pid,ppid,pgid,sid,comm 观察进程树结构，确认子进程 PGID 是否一致。
掌握进程组机制，不仅能解决超时清理问题，更是构建健壮 CLI 工具、容器化任务调度器和系统监控组件的关键基础能力。
