本文介绍一种轻量、安全的 go 并发模式：根据运行时标志动态启用/禁用统计 goroutine，并避免向未初始化通道发送数据导致 panic，同时确保主流程正确同步与资源清理。
本文介绍一种轻量、安全的 go 并发模式：根据运行时标志动态启用/禁用统计 goroutine，并避免向未初始化通道发送数据导致 panic，同时确保主流程正确同步与资源清理。
在 Go 的并发编程中，常需根据配置或命令行标志（如 --stats）决定是否启用某条处理流水线（例如统计分析）。若简单地“只启动 goroutine 而不创建对应 channel”，则生产者向 nil channel 发送数据会立即 panic；反之，若始终创建 channel 又会造成无谓内存与调度开销。理想的方案是：通道按需创建、goroutine 按需启动、通信逻辑安全兜底、终止信号统一协调。
以下是一个经过优化的实现范式：
var (
matches = make(chan []string, 1024) // 始终存在的处理通道
stats chan []string // 仅当启用统计时才初始化
done = make(chan struct{}) // 用于通知完成（建议用 close 而非发送）
)
func main() {
options() // 解析 flag、设置 reg、col、loc 等
go produce(readCSV(loc))
go process()
if *enableStats { // 假设 flag.BoolVar(&enableStats, "stats", false, "enable statistics collection")
stats = make(chan []string, 1024)
go statistics()
}
<-done // 等待生产完成（注意：此处应确保 done 在 produce 中被 close）
}关键改进点如下：
- 延迟通道初始化：stats 声明为 chan []string 类型但不初始化；仅当 *enableStats == true 时才调用 make(chan []string, 1024)，避免空 channel 引发 panic。
- 生产者安全写入：在 produce 中通过 if stats != nil { stats
- 消费者优雅退出：process 和 statistics 均使用 select + done 通道监听，配合 close(done) 实现非阻塞退出，避免无限 for {} 导致 goroutine 泄漏。
- 通道关闭语义明确：done 应在 produce 结束时 close(done)（而非 done
完整修正版核心逻辑示例：
func produce(entries [][]string) {
regex, err := regexp.Compile(reg)
if err != nil {
log.Fatal("invalid regex:", reg)
}
for _, each := range entries {
if regex.MatchString(each[col]) {
matches <- each
if stats != nil {
stats <- each // 安全：仅当 stats 已初始化
}
}
}
close(matches) // 告知 consumers 数据已发完
close(done) // 通知 main 协程可退出
}
func process() {
for match := range matches { // 使用 range 自动处理 closed channel
if len(match) > 0 {
// 处理单条匹配记录
}
}
}
func statistics() {
for stat := range stats { // 同样使用 range，简洁且健壮
if len(stat) > 0 {
// 收集统计指标（如计数、分布、耗时等）
}
}
}⚠️ 注意事项：
- 切勿对未初始化的 channel 执行发送（
- 避免使用带缓冲的 done chan bool 并发送值来同步——应改用无缓冲 chan struct{} + close()，更语义化且防止多次关闭 panic；
- 若 statistics 需聚合最终结果（如总条数、平均值），应在 for range stats 循环结束后执行汇总，而非在循环内实时打印；
- 生产环境中建议为所有 channel 设置合理缓冲容量（如本例中的 1024），并结合 context.Context 支持超时与取消。
该模式兼顾性能、可读性与健壮性，是 Go 中实现“条件化并发流水线”的推荐实践。
