本文介绍如何在 go 中实时捕获并处理正在运行的子进程（如 bash 脚本）的标准输出，避免阻塞等待进程结束，支持边执行边读取、条件中断及资源安全释放。
本文介绍如何在 go 中实时捕获并处理正在运行的子进程（如 bash 脚本）的标准输出，避免阻塞等待进程结束，支持边执行边读取、条件中断及资源安全释放。
要在 Go 中真正实现实时流式读取子进程输出（而非等其结束后一次性获取），关键在于避免使用 cmd.Run()（它会同步阻塞），转而使用 cmd.Start() + io.ReadCloser 配合 bufio.Scanner 或 bufio.Reader 进行非阻塞/逐行读取。同时需注意：cmd.Stdout = os.Stdout 仅适用于简单透传输出，无法满足“实时处理+提前退出+子进程继续运行”的进阶需求——这正是原问题中 P.S.2 和 P.S.4 所强调的核心场景。
✅ 正确做法：启动后流式读取 + 条件中断 + 安全清理
以下代码完整实现：
- 实时逐行读取 bash_loop.sh 输出；
- 读到 "3" 时立即返回结果，不等待脚本结束；
- 子进程在 Go 主程序退出后仍继续运行（即“分离”模式）；
- 防止僵尸进程（通过 cmd.Process.Release() 显式释放对子进程的引用）。
package main
import (
"bufio"
"fmt"
"os/exec"
"time"
)
func runBashRealtime(rootDir string) (string, error) {
burstingScript := "bash_loop.sh" // 或 path.Join(rootDir, "bash_loop.sh")
cmd := exec.Command("/bin/sh", burstingScript)
stdout, err := cmd.StdoutPipe()
if err != nil {
return "", fmt.Errorf("failed to get stdout pipe: %w", err)
}
if err := cmd.Start(); err != nil {
return "", fmt.Errorf("failed to start command: %w", err)
}
defer cmd.Process.Release() // ? 关键：释放进程引用，避免僵尸进程
scanner := bufio.NewScanner(stdout)
for scanner.Scan() {
line := scanner.Text()
fmt.Println("→", line) // 实时打印（可替换为任意处理逻辑）
if line == "3" {
// ✅ 提前返回，不调用 cmd.Wait()，子进程继续运行
return line, nil
}
}
if err := scanner.Err(); err != nil {
return "", fmt.Errorf("scanner error: %w", err)
}
// 若未提前退出，则等待完成（可选）
if err := cmd.Wait(); err != nil {
return "", fmt.Errorf("command finished with error: %w", err)
}
return "", nil
}
func main() {
result, err := runBashRealtime(".")
if err != nil {
fmt.Printf("Error: %v\n", err)
return
}
if result != "" {
fmt.Printf("Found target: %s\n", result)
}
}⚠️ 注意事项与最佳实践
- 不要用 cmd.Run()：它等同于 Start() + Wait()，必然阻塞至结束，无法实时响应。
- cmd.Stdout = os.Stdout 是简化方案，但不可控：它绕过 Go 程序逻辑，无法做条件判断、解析或提前中断；仅适用于纯日志透传。
- cmd.Process.Release() 是防僵尸关键：当不调用 cmd.Wait() 时，Go 运行时不会自动 reap 子进程；显式调用 Release() 后，操作系统将接管该进程生命周期（类似 Unix 的 setsid 或 nohup 效果）。
- 超时控制建议：生产环境应添加 context.WithTimeout 控制 scanner.Scan() 最大等待时间，防止因子进程卡死导致主程序挂起。
- 并发安全：若需多路处理（如同时读 Stdout 和 Stderr），推荐使用 golang.org/x/exp/io 或 io.MultiReader 封装，或启动 goroutine 分别处理。
✅ 总结
Go 原生 exec 包完全支持子进程实时 I/O 流处理。核心模式是：
exec.Command → cmd.StdoutPipe() → cmd.Start() → bufio.Scanner.Scan() 循环读取 → 按需中断 → cmd.Process.Release() 释放控制权。
这一模式既满足“边跑边看”的调试需求，也支撑生产级的异步事件驱动处理（如监听部署日志中的 READY 标志、CI 流水线中的阶段完成信号等）。
