掌握Go语言并发编程的关键：通道（Channel）的正确关闭时机（详解Go通道关闭与goroutine通信最佳实践）

谁应该负责关闭通道？

这是最关键的问题！记住这个黄金法则：

“发送方负责关闭通道。”

因为只有发送方知道什么时候数据发送完毕。如果接收方或其他 goroutine 关闭通道，很可能在发送方还在写入时触发 panic（向已关闭的通道发送数据会 panic）。

正确关闭通道的示例

下面是一个典型的生产者-消费者模型，展示如何安全关闭通道：

package mainimport (    "fmt"    "sync")func main() {    ch := make(chan int)    var wg sync.WaitGroup    // 启动生产者    go func() {        defer close(ch) // ✅ 正确：由发送方关闭        for i := 1; i <= 5; i++ {            ch <- i        }    }()    // 启动消费者    wg.Add(1)    go func() {        defer wg.Done()        for v := range ch { // 自动在通道关闭后退出            fmt.Println("收到:", v)        }    }()    wg.Wait()}  

在这个例子中，生产者 goroutine 在发送完所有数据后调用 close(ch)。消费者使用 range 遍历通道，当通道关闭后自动退出循环。这正是 goroutine通信 的优雅方式。

常见错误与陷阱

• 错误1： 多个 goroutine 同时向同一个通道发送数据，并都试图关闭它 → 可能重复关闭，引发 panic。
• 错误2： 接收方关闭通道 → 如果此时还有发送操作，会 panic。
• 错误3： 忘记关闭通道 → 使用 range 的接收者永远阻塞，造成 goroutine 泄漏。

多生产者场景怎么办？

如果有多个生产者，不能让每个都关闭通道。这时可以使用 sync.WaitGroup 协调，在所有生产者完成后再由一个专用 goroutine 关闭通道：

var wgProd sync.WaitGroupch := make(chan int)// 启动多个生产者for i := 0; i < 3; i++ {    wgProd.Add(1)    go func(id int) {        defer wgProd.Done()        for j := 0; j < 2; j++ {            ch <- id*10 + j        }    }(i)}// 专用关闭 goroutinego func() {    wgProd.Wait()    close(ch) // 所有生产者完成后关闭}()// 消费者for v := range ch {    fmt.Println(v)}  

总结

在 Go语言通道使用 中，牢记以下几点：

1. 通道应由发送方关闭；
2. 不要向已关闭的通道发送数据；
3. 使用 range 接收时，务必确保通道会被关闭；
4. 多生产者场景下，用 WaitGroup 协调后统一关闭。

掌握这些原则，你就能避免绝大多数与通道关闭相关的并发 bug，写出更可靠的 Go语言并发编程 代码！