本文介绍如何在 go 中通过 select + channel 实现后台周期性执行命令（如 ps）的同时，不阻塞地监听停止信号，确保程序响应及时、逻辑清晰、资源可控。
本文介绍如何在 go 中通过 select + channel 实现后台周期性执行命令（如 ps）的同时，不阻塞地监听停止信号，确保程序响应及时、逻辑清晰、资源可控。
在 Go 中实现“持续执行命令 + 可随时中断”的典型场景（例如用 ps 定期采集 CPU/内存使用率），关键在于避免 Goroutine 因等待信号而阻塞命令执行，或因频繁轮询导致资源浪费。核心解法是使用 select 语句配合非阻塞通道操作与定时器，而非简单循环中混用 <-stop 和 cmd.Run()——后者会导致每次执行完命令后才检查信号，延迟高且不可控。
以下是一个生产就绪的示例，封装为可复用的监控函数：
package main
import (
"fmt"
"os/exec"
"time"
)
// monitorPS 每隔 interval 执行 ps 命令，直到收到 stop 信号
func monitorPS(stop <-chan struct{}, interval time.Duration) {
ticker := time.NewTicker(interval)
defer ticker.Stop()
for {
select {
case <-stop:
fmt.Println("监控已停止")
return
case <-ticker.C:
// 执行 ps 命令：按需定制列（如 -o pid,%cpu,%mem,comm）
cmd := exec.Command("ps", "-eo", "pid,%cpu,%mem,comm")
out, err := cmd.Output()
if err != nil {
fmt.Printf("执行 ps 失败: %v\n", err)
continue // 失败不中断，继续下一轮
}
fmt.Printf("=== %s ===\n%s", time.Now().Format("15:04:05"), out)
}
}
}
func main() {
stop := make(chan struct{})
go monitorPS(stop, 2*time.Second)
// 模拟主程序运行 10 秒后发送停止信号
time.Sleep(10 * time.Second)
close(stop) // 或 send: stop <- struct{}{}
}✅ 关键要点说明：
- 使用 time.Ticker 替代 time.After 循环，更高效且语义明确（适合固定间隔任务）；
- select 中 <-stop 与 <-ticker.C 并列，任一就绪即执行对应分支，完全非阻塞；
- cmd.Output() 同步执行命令并捕获输出；若需更高并发性（如多命令并行），可配合 context.WithTimeout 控制单次执行超时；
- close(stop) 是推荐的终止方式（接收方检测到 channel 关闭即退出），比发送空结构体更符合 Go 习惯；若需多次触发停止逻辑，可用 stop <- struct{}{} + default 分支做非阻塞检查。
⚠️ 注意事项：
- 避免在 select 中直接调用阻塞型 I/O（如未设超时的 cmd.Run()）——应始终包裹在 case 分支内，并考虑错误处理与重试；
- 若需精确控制命令执行频率（如“每秒最多一次”，即使前次耗时较长），ticker 是最佳选择；若要求“尽可能高频执行”，则改用 default 分支 + time.Sleep 微调；
- 生产环境建议添加日志库（如 log/slog）替代 fmt.Printf，并考虑将 ps 输出解析为结构化数据（如 []Process）便于后续分析。
通过该模式，你既能享受 ps 的灵活列定制能力，又获得与 top 相当甚至更优的信号响应实时性——真正实现“运行不卡顿，停止不延迟”。
