for-range遍历Go无缓冲通道防死锁方法

学习Golang要努力，但是不要急！今天的这篇文章《for-range 遍历 Go 无缓冲通道避死锁技巧》将会介绍到等等知识点，如果你想深入学习Golang，可以关注我！我会持续更新相关文章的，希望对大家都能有所帮助！

Go 中对未关闭的无缓冲通道执行 `for range` 会永久阻塞，导致所有 goroutine 休眠而触发死锁；必须在所有发送者完成写入后显式关闭通道，才能让 range 循环正常退出。

在 Go 并发编程中，for ele := range ch 是遍历通道的惯用写法，但它有一个关键前提：该通道必须被关闭（closed），否则循环将永远等待下一个值——即使所有生产者 goroutine 已执行完毕并退出。

你遇到的死锁正是源于此：程序启动了 3 个 sum_up goroutine 向 my_channel 发送数据（对应 i=2,3,4，结果分别为 1, 3, 6），主 goroutine 通过 for range 成功读取这 3 个值并打印。但此时通道仍处于打开状态，range 循环继续尝试接收第 4 个值，而所有 sum_up goroutine 已结束、无其他 goroutine 向通道写入，也无人关闭通道——于是主 goroutine 阻塞，其余 goroutine 全部退出，最终触发 fatal error: all goroutines are asleep - deadlock!。

✅ 正确解法是：确保通道在所有发送操作完成后被关闭。由于发送操作在多个 goroutine 中异步进行，不能由主 goroutine 直接判断何时关闭，因此需借助同步原语协调。常用且推荐的方式是 sync.WaitGroup：

package main

import (
    "fmt"
    "sync"
)

func sum_up(my_int int, cs chan int, wg *sync.WaitGroup) {
    defer wg.Done() // 确保无论函数如何返回都计数减一
    my_sum := 0
    for i := 0; i < my_int; i++ {
        my_sum += i
    }
    cs <- my_sum
}

func main() {
    wg := &sync.WaitGroup{}
    my_channel := make(chan int)

    // 启动 3 个并发任务
    for i := 2; i < 5; i++ {
        wg.Add(1)
        go sum_up(i, my_channel, wg)
    }

    // 单独 goroutine 等待全部完成并关闭通道
    go func() {
        wg.Wait()
        close(my_channel) // 关键：关闭通道，通知 range 循环退出
    }()

    // 主 goroutine 安全遍历（自动在 close 后终止）
    for ele := range my_channel {
        fmt.Println(ele)
    }

    fmt.Println("Done")
}

? 关键要点总结：

• for range ch 仅在通道 关闭后自动退出，它不会因“暂无数据”而停止，也不会感知发送者是否存活；
• 关闭通道的责任应由协调者（通常是启动 goroutine 的一方）承担，而非发送者——因为单个发送者无法知道其他发送者是否已完成；
• 使用 defer wg.Done() 可提升代码健壮性，避免 panic 时漏掉计数；
• 切勿在多个 goroutine 中重复调用 close(ch)，会导致 panic；确保仅关闭一次（本例中由 wg.Wait() 后的唯一 goroutine 执行）；
• 若需带超时或更复杂控制，可结合 select + time.After 或 context，但本场景 WaitGroup + close 是最简洁、标准的解决方案。

遵循这一模式，即可安全、清晰地实现多生产者 → 单消费者通道遍历，彻底规避此类死锁问题。

以上就是《for-range遍历Go无缓冲通道防死锁方法》的详细内容，更多关于的资料请关注golang学习网公众号！