本文详解 go 中通过 channel 协调多 goroutine 并发写入文件的正确模式，指出原代码因通道阻塞导致死锁的根本原因，并提供可运行的修复方案与最佳实践。
本文详解 go 中通过 channel 协调多 goroutine 并发写入文件的正确模式，指出原代码因通道阻塞导致死锁的根本原因，并提供可运行的修复方案与最佳实践。
在 Go 中，使用无缓冲 channel（如 make(chan string)）进行 goroutine 间通信时，发送操作会阻塞，直到有另一个 goroutine 执行对应的接收操作。这正是原代码出现“文件创建成功但无内容写入”现象的核心原因：concurrent(1) 和 concurrent(2) 向 output 通道发送字符串时，由于 printOutput() 尚未启动、无人接收，两个 goroutine 在 goroutine 死锁。
修复的关键在于：确保接收者（消费者）早于发送者（生产者）就绪并持续监听通道。最直接的方式是将 printOutput() 作为独立 goroutine 在 main 中优先启动：
func main() {
go printOutput() // ✅ 提前启动消费者，避免阻塞
wg.Add(2)
go concurrent(1)
go concurrent(2)
wg.Wait()
close(output) // ✅ 关闭通道，通知 for-range 退出
}
此时执行流程变为：
- printOutput() 启动，进入 for msg := range output 循环，阻塞在通道接收处；
- concurrent(1) 和 concurrent(2) 发送数据，被 printOutput() 即时接收并写入文件；
- wg.Wait() 返回后，close(output) 终止 range 循环，printOutput() 正常退出。
⚠️ 注意事项：
- 切勿在 printOutput() 中使用 defer f.Close() 后再执行 range：defer 仅在函数返回时触发，而 range 是无限循环（除非通道关闭），导致文件句柄长期不释放。当前代码已正确处理。
- 务必关闭通道：close(output) 是 for range 退出的唯一信号，否则消费者 goroutine 将永远等待。
- 考虑缓冲通道优化：若生产者写入频率高、消费者处理慢，可改用带缓冲通道（如 make(chan string, 100)）缓解阻塞，但需权衡内存占用与背压控制。
- 错误处理增强建议：实际项目中，f.WriteString 可能失败，应检查返回值并记录错误，避免静默丢弃数据。
综上，Go 的 channel 并发模型强调“协作式通信”，而非“单向推送”。设计时须明确角色（生产者/消费者）、启动顺序与生命周期管理——本例中，让消费者先行就位，是打破死锁、实现安全并发写入的基石。
