本文介绍一种轻量、安全的 go 并发模式：根据运行时标志动态启用/禁用统计 goroutine，并避免向未初始化 channel 发送数据导致 panic；核心在于延迟初始化 channel、空值保护发送逻辑，以及使用 select + done 通道优雅终止协程。
本文介绍一种轻量、安全的 go 并发模式：根据运行时标志动态启用/禁用统计 goroutine，并避免向未初始化 channel 发送数据导致 panic；核心在于延迟初始化 channel、空值保护发送逻辑，以及使用 select + done 通道优雅终止协程。
在构建高并发数据处理流水线时，常需按需启用辅助分析模块（如统计收集），而非始终运行——否则不仅浪费 CPU 和内存资源，还可能因向未启动 Goroutine 的 channel 发送数据而引发 panic（send on nil channel）。上述问题中，statistics() Goroutine 仅在特定标志启用时才应参与工作，但原始代码中 stats channel 始终为 nil，直接写入将崩溃。
✅ 正确做法：延迟初始化 + 空值防护 + 优雅退出
关键改进点有三：
- 声明但不初始化 channel：var stats chan []string —— 显式留空，避免误用；
- 按需创建并启动 Goroutine：仅当 flag 为真时，才 make(chan []string, 1024) 并 go statistics()；
- 生产端防御性写入：if stats != nil { stats
此外，原代码中消费者 Goroutine 使用无限 for {
func process() {
for {
select {
case match := <-matches:
if len(match) > 0 {
// 处理匹配项：解析、转换、写入等
handleMatch(match)
}
case <-done:
log.Info("process goroutine exited gracefully")
return
}
}
}
func statistics() {
for {
select {
case stat := <-stats:
if len(stat) > 0 {
updateStats(stat) // 如计数、采样、直方图更新
}
case <-done:
log.Info("statistics goroutine exited gracefully")
return
}
}
}
⚠️ 注意事项：
- done 通道应在所有生产者完成时 关闭（close(done)），而非仅发送 true；消费者应通过
- 若 matches 或 stats 是带缓冲的 channel，务必确保容量合理（如示例中 1024），防止生产者因缓冲满而阻塞；
- 所有 Goroutine 启动后建议添加日志或指标埋点，便于可观测性调试；
- 更进一步，可将 stats 封装为可选的 *chan []string 类型，语义更清晰。
✅ 完整可运行骨架（精简版）
var (
matches = make(chan []string, 1024)
stats chan []string // nil by default
done = make(chan struct{})
)
func main() {
options() // 解析 flag、配置等
go produce(readCSV(loc))
go process()
if *enableStats { // 假设 flag.BoolVar(&enableStats, "stats", false, "enable statistics collection")
stats = make(chan []string, 1024)
go statistics()
}
<-done
}
func produce(entries [][]string) {
re, err := regexp.Compile(reg)
if err != nil {
log.Fatal(err)
}
for _, row := range entries {
if re.MatchString(row[col]) {
matches <- row
if stats != nil {
stats <- row // 安全：仅当启用统计时才发送
}
}
}
close(done) // 所有生产完成，通知消费者退出
}该方案零依赖、无竞态、符合 Go 的“不要通过共享内存来通信，而应通过通信来共享内存”哲学，是生产环境推荐的条件并发控制范式。
