本文详解 go 中在 for 循环内启动 goroutine 的常见陷阱（如变量捕获错误、通道阻塞），并提供可落地的并发频次统计实现方案，涵盖通道设计、同步控制与结果聚合全流程。
本文详解 go 中在 for 循环内启动 goroutine 的常见陷阱（如变量捕获错误、通道阻塞），并提供可落地的并发频次统计实现方案，涵盖通道设计、同步控制与结果聚合全流程。
在 Go 并发编程中，一个经典误区是：直接在 for 循环中启动 goroutine 并向无缓冲通道发送数据，却未同步消费或关闭通道。你提供的 ConcurrentFrequency 函数之所以只返回单个结果，根本原因有二：
- 通道未被持续消费：return <-c 仅接收第一个值，后续 goroutine 发送时因通道无缓冲而永久阻塞；
- 循环变量捕获错误（虽本例已用参数传值规避）：原代码 (i int) 显式传参是正确的，但若写成 go func() { c <- Frequency(l[i]) }() 则会因闭包捕获循环变量 i 导致所有 goroutine 访问同一（最终）索引值——这是另一高频陷阱。
✅ 正确解法需满足三个关键原则：
- 启动 goroutine 前确保通道可接收（通过另启 goroutine 封装整个并发流程）；
- 用 sync.WaitGroup 精确等待所有任务完成；
- 显式关闭通道以支持 range 消费，避免死锁。
以下是生产就绪的实现：
func ConcurrentFrequency(l []string) chan FreqMap {
c := make(chan FreqMap)
go func() {
var wg sync.WaitGroup
wg.Add(len(l))
for _, s := range l {
go func(text string) {
defer wg.Done()
c <- Frequency(text) // 非阻塞：只要消费者及时读取
}(s)
}
wg.Wait()
close(c) // 关键：通知消费者发送结束
}()
return c
}
// 调用示例：聚合所有结果
func CombineFreqMaps(ch chan FreqMap) FreqMap {
result := make(FreqMap)
for freqMap := range ch { // range 自动阻塞直到 channel 关闭
for rune, count := range freqMap {
result[rune] += count
}
}
return result
}
// 使用方式
func main() {
inputs := []string{"hello", "world", "golang"}
freqChan := ConcurrentFrequency(inputs)
total := CombineFreqMaps(freqChan)
fmt.Println(total) // map[100:1 101:2 103:2 104:1 108:4 110:1 111:3 114:1 119:1 121:1]
}⚠️ 注意事项：
- 永远不要对无缓冲通道做多次发送而不消费：c <- x 在无缓冲通道上是同步操作，必须有 goroutine 同时接收才能继续；
- range 是安全消费通道的最佳实践：它自动处理关闭信号，且比手动 for { select { case v := <-c: ... } } 更简洁；
- 避免在 goroutine 内部直接操作共享 map：此处每个 Frequency() 返回独立 FreqMap，再由主 goroutine 合并，彻底规避竞态条件；
- 若输入量极大，可考虑带缓冲通道（如 make(chan FreqMap, len(l))）缓解瞬时压力，但非必需。
此模式（goroutine 封装 + WaitGroup + 关闭通道 + range 消费）是 Go 并发编程的黄金范式，适用于任何“扇出-扇入”（fan-out/fan-in）场景，如批量 API 调用、日志分析或数据转换流水线。
