本文介绍一种轻量、安全的 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 := 0 {
// 处理匹配项：解析、转换、写入等
handleMatch(match)
}
case 0 {
updateStats(stat) // 如计数、采样、直方图更新
}
case <blockquote>
<p>⚠️ 注意事项：</p>
<ul>
<li>done 通道应在所有生产者完成时 <strong>关闭</strong>（close(done)），而非仅发送 true；消费者应通过 </li>
<li>若 matches 或 stats 是带缓冲的 channel，务必确保容量合理（如示例中 1024），防止生产者因缓冲满而阻塞；</li>
<li>所有 Goroutine 启动后建议添加日志或指标埋点，便于可观测性调试；</li>
<li>更进一步，可将 stats 封装为可选的 *chan []string 类型，语义更清晰。</li>
</ul>
</blockquote><h3>✅ 完整可运行骨架（精简版）</h3><pre class="brush:php;toolbar:false;">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()
}
<p>该方案零依赖、无竞态、符合 Go 的“不要通过共享内存来通信，而应通过通信来共享内存”哲学，是生产环境推荐的条件并发控制范式。</p>
