Go语言并发任务编排教程

本文深入讲解了Go语言中并发任务编排的核心实践，聚焦于如何让多个goroutine“齐步走”——既可靠完成又安全收尾：通过sync.WaitGroup精准控制启停时机，强调Add()必须在goroutine启动前、Done()必须确保执行（常配合defer）、Wait()实现主协程同步等待，并警示常见竞态与panic陷阱；进一步结合context.WithTimeout等机制，赋予并发任务超时控制与优雅取消能力，强调所有子任务需主动监听ctx.Done()并适配阻塞操作，彻底摒弃time.Sleep等不可靠方案，助你写出健壮、可维护的高并发Go代码。

用 sync.WaitGroup 控制一组 goroutine 的启停时机

并发任务编排的第一关，不是怎么“快”，而是怎么“齐”——所有子任务完成后再统一收尾。直接用 time.Sleep 等是反模式，根本不可靠。

核心做法：在启动 goroutine 前调用 wg.Add(1)，每个 goroutine 结束前调用 wg.Done()，主 goroutine 用 wg.Wait() 阻塞等待全部完成。

常见错误：

• wg.Add() 放在 goroutine 内部（导致计数漏加或竞态）
• 忘记调用 wg.Done()（程序永远卡在 Wait()）
• 重复调用 wg.Add() 且没配平（panic: negative WaitGroup counter）

示例片段：

var wg sync.WaitGroup
for _, job := range jobs {
    wg.Add(1)
    go func(j Task) {
        defer wg.Done()
        process(j)
    }(job)
}
wg.Wait() // 这里才真正等齐所有 task

用 context.Context 实现带超时/取消的并发调度

真实场景中，并发任务不能无限期运行，比如 HTTP 请求、数据库查询、第三方 API 调用都需要兜底控制。靠轮询或全局标志位太糙，context 是 Go 官方推荐的传播取消信号和截止时间的方式。

关键点：

• 用 context.WithTimeout(ctx, 5*time.Second) 包装出带超时的新 ctx
• 所有子 goroutine 必须监听 ctx.Done() 并及时退出（尤其注意阻塞 I/O 操作要支持 context，如 http.Client 设置 Timeout 或用 ctx 构造 request）
• 不要把 context.Background() 直接传进长期运行的 goroutine——它永远不会被取消

典型误用：select { case —— 这会忙等。正确写法是让 doWork() 本身支持 ctx，或用 case 配合阻塞操作。

用 errgroup.Group 统一收集并发错误并支持上下文取消

当多个并发任务中任意一个出错就要整体失败（如批量上传文件），手动维护错误变量 + sync.Once 很繁琐。errgroup.Group 就是为此设计的轻量封装。

它自动集成 context 取消，并保证只返回第一个非 nil 错误：

• 调用 eg.Go(func() error { ... }) 启动任务，函数返回 error
• 调用 eg.Wait() 阻塞直到全部完成或任一出错
• 若底层 context 被取消，所有未开始的 goroutine 不会启动，已运行的应主动检查 ctx.Err()

注意：errgroup 不处理 panic，仍需在 goroutine 内加 recover；也不提供重试逻辑，错误后整个组就结束了。

别忽略 goroutine 泄漏：什么时候该用带缓冲的 channel 控制并发数

无节制起 goroutine（比如 for 循环里直接 go f()）容易打爆内存或压垮下游服务。这不是调度问题，是资源失控。

标准解法是用带缓冲的 chan struct{} 当作“令牌桶”：

• 初始化 sem := make(chan struct{}, 10) 表示最多 10 个并发
• 每个 goroutine 启动前写入 sem （阻塞直到有空位）
• 结束后从 sem 读出 <-sem 归还令牌

更简洁的做法是用 golang.org/x/sync/semaphore，但要注意它的 Acquire() 是阻塞且可被 context 取消的，比手写 channel 更健壮。泄漏常发生在：channel 没关闭、goroutine 因 panic 未执行 <-sem、或忘记在 defer 中归还令牌。

以上就是《Go语言并发任务编排教程》的详细内容，更多关于的资料请关注golang学习网公众号！