用 WaitGroup + channel 实现批量并发任务_网络技术

用 WaitGroup + channel 实现批量并发任务

发布时间 - 2026-01-29 00:00:00 点击率：次

WaitGroup 负责等待所有 goroutine 结束，channel 负责传递结果或协调节奏；正确做法是启动前 wg.Add(n)，每个 goroutine 结尾 defer wg.Done() 后再发结果到 channel，并在所有发送完成后关闭 channel。

WaitGroup 和 channel 各自该管什么

WaitGroup 负责“等所有 goroutine 结束”，channel 负责“传结果或协调节奏”。混用时最常见错误是：用 channel 去替代 WaitGroup 的等待逻辑，比如反复 range 一个未关闭的 channel 导致死锁，或者漏掉 wg.Done() 还指望从 channel 收完就自动退出。

正确分工：wg.Add() 在启动 goroutine 前调用；每个 goroutine 结尾必须调用 wg.Done()（最好用 defer）；channel 仅用于输出结果、限流或通知完成，不承担生命周期管理职责。

并发任务结果收集的典型写法

批量任务通常需要汇总返回值，这时 channel 是自然选择，但必须配合 WaitGroup 确保所有发送完成后再关闭 channel。否则消费者可能提前退出，漏收数据。

启动前 wg.Add(n)，n 是任务总数
每个 goroutine 执行完后 defer wg.Done()，再向 channel 发送结果（如 ch ）
另起一个 goroutine 调用 wg.Wait()，然后 close(ch)
主 goroutine 用 for range ch 安全接收，无需担心 channel 未关闭

ch := make(chan int, 10)
wg := &sync.WaitGroup{}
for i := 0; i < 5; i++ {
    wg.Add(1)
    go func(id int) {
        defer wg.Done()
        ch <- id * 2
    }(i)
}
go func() {
    wg.Wait()
    close(ch)
}()
for res := range ch {
    fmt.Println(res)
}

为什么不能只用 channel 不用 WaitGroup

只靠 close(ch) 并不能保证所有 goroutine 已执行完毕——你可能在某个 goroutine 还没走到 ch 那行时就关闭了 channel，导致它 panic：send on closed channel。反过来，如果不用 channel 而只用 wg.Wait()，又拿不到中间结果。

关键点在于：WaitGroup 保证“执行结束”，channel 保证“通信安全”。二者不是替代关系，而是互补关系。尤其当任务耗时差异大、部分失败需继续执行其余任务时，这种组合能避免过早关闭 channel 或遗漏结果。

容易被忽略的缓冲区和关闭时机

channel 缓冲区大小设太小会导致 goroutine 阻塞在发送端，拖慢整体进度；设太大则浪费内存。更隐蔽的问题是关闭 channel 的 goroutine 可能比所有 worker 启动得还慢，造成竞态。

缓冲区建议设为任务数 cap(ch) == n，或略大（如 n+1），避免阻塞
close(ch) 必须在 wg.Wait() 之后，且只能由一个 goroutine 执行
不要在 worker 内部判断 “我是最后一个” 然后关 channel —— 没有可靠方式识别“最后一个”
如果任务可能 panic，defer wg.Done() 仍有效，但需额外 recover，否则 channel 不会关闭

实际项目里，真正难的不是写对这几行，而是想清楚：哪些数据必须按序收？哪些可以丢？失败要不要重试？这些决策会直接决定 channel 类型（带缓冲/无缓冲）、是否用带超时的 select、以及是否引入 error channel。

# go # ai # golang # 并发 # channel # 死锁 # 我是 # 自然选择 # 完成后 # 还没 # 走到 # 设为 # 并在 # 不承担 # 能在

相关栏目：【网站优化151355 】【网络推广146373 】【网络技术251813 】【 AI营销90571 】

上一篇：PPT如何制作类似电影开头的文字由远及近效果_利用缩放动画与

下一篇：PDF怎么批量打印_PDF多文件打印操作指南

相关栏目网站优化
网络推广
网络技术
AI营销

最新文章 Sublime怎么一键压缩JS代码 Su sublime如何在搜索中使用正则表达式 Sublime如何设置透明窗口效果 Su mysql如何设计商品表结构_mysql css属性背景图不显示怎么办_通过检查路如何使用Golang实现排序_Golan 农历闰月是怎么回事_为合回归年加一月调整塑造《刺客信条》艾吉奥传奇的编剧离开育碧 1英里等于多少公里 1mile和km的换 css grid布局中行和列是如何定义的 PS批量旋转和翻转图片，快速校正图片方向 C# Swagger UI自定义方法 C OPPO手机九宫格和全键盘怎么切换_OP Go语言如何实现用户登录注册_Golan 1节飞行速度多少公里每小时 1节是多少公纸嫁衣8千子树第五章庙门怎么开启庙门 Laravel 多行数据编辑表单中实现逐明日之后如何提升钓鱼等级明日之后提升钓支付宝怎样查年度账单_支付宝年度账单查看 C# 多线程UI更新Dispatcher

上一篇：PPT如何制作类似电影开头的文字由远及近效果_利用缩放动画与

下一篇：PDF怎么批量打印_PDF多文件打印操作指南