本文介绍一种轻量、安全的 go 并发模式：根据运行时标志动态启用/禁用统计 goroutine，并避免向未初始化通道发送数据导致 panic；核心在于延迟通道初始化、空指针防护及使用 select + done 通道优雅退出。
本文介绍一种轻量、安全的 go 并发模式：根据运行时标志动态启用/禁用统计 goroutine，并避免向未初始化通道发送数据导致 panic；核心在于延迟通道初始化、空指针防护及使用 select + done 通道优雅退出。
在 Go 的并发编程中，常需根据配置或命令行标志（如 -stats）决定是否启用某类后台处理逻辑（例如统计收集）。若简单地在 main() 中无条件启动 Goroutine 并向通道发送数据，而该通道未被初始化，则会导致运行时 panic（send on nil channel）。上述问题中的 statistics() Goroutine 和 stats 通道正是典型场景。
正确做法是：延迟通道初始化，并在生产端做显式空值检查。
首先，将 stats 声明为未初始化的 nil 通道：
var stats chan []string // nil channel — 安全，可参与 select，但不可 send/receive
然后，在 main() 中仅当条件满足时才创建缓冲通道并启动 Goroutine：
func main() {
options()
go produce(readCSV(loc))
go process()
if *enableStats { // 假设 flag.BoolVar(&enableStats, "stats", false, "enable statistics collection")
stats = make(chan []string, 1024)
go statistics()
}
<-done
}关键在于 produce() 函数中对 stats 的防护性写入：
if regex.MatchString(each[col]) {
matches <- each
if stats != nil { // ✅ 必须检查！向 nil channel 发送会 panic
stats <- each
}
}此外，消费者 Goroutine（process 和 statistics）不应依赖“空切片”作为终止信号（如原代码中 len(match) != 0），这既不可靠（空切片可能合法）又易出错。应改用 select 监听 done 通道实现优雅退出：
func process() {
for {
select {
case match := <-matches:
// PROCESS match — 此处 match 非 nil，且长度有效
case <-done:
log.Info("process: exiting gracefully")
return
}
}
}
func statistics() {
for {
select {
case stat := <-stats:
// STATISTICS stat
case <-done:
log.Info("statistics: exiting gracefully")
return
}
}
}⚠️ 重要注意事项：
- done 通道应在 produce 结束前 关闭（而非仅发送 true），否则 select 中的
- 所有接收方需使用 select + done，而非无限 for {
- 缓冲通道大小（如 1024）应根据吞吐量与内存权衡，过大会增加 GC 压力，过小可能导致生产者阻塞；
- 若后续需支持热启停统计功能，可进一步封装为带 sync.Once 或 atomic.Bool 控制的状态机，但本例静态条件已足够简洁高效。
这种模式兼顾了灵活性、安全性与可维护性，是 Go 生产环境中推荐的条件并发实践。
