使用context和time实现超时与取消，结合WaitGroup管理并发任务，确保goroutine及时退出。通过WithTimeout设置超时，select监听ctx.Done()与任务完成信号，避免资源泄露。每个worker响应取消指令，主流程统一等待或超时退出，并传递context至网络调用等操作，实现层级化取消控制，保障系统稳定性。
在Go语言开发中，处理并发任务的超时与取消是保障系统稳定性和资源高效利用的关键。当多个任务并行执行时，若某个任务长时间未完成或需要提前终止，必须有机制能及时响应。Golang通过 context 包和 time 相关功能提供了简洁而强大的支持。
使用 Context 控制任务生命周期
Context 是 Go 中用于传递请求范围的元数据、取消信号和截止时间的核心工具。在并发任务中，它能统一协调多个 goroutine 的退出时机。
常见做法是为每个任务派生一个带取消功能的子 context，并在任务内部定期检查是否已被取消。
- 调用 context.WithCancel 创建可手动取消的 context
- 使用 context.WithTimeout 设置自动超时触发取消
- 在 goroutine 内部通过 select 监听 ctx.Done() 通道
示例代码：
立即学习“go语言免费学习笔记（深入）”；
ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second) defer cancel()go func() { select { case <-time.After(5 * time.Second): fmt.Println("任务完成") case <-ctx.Done(): fmt.Println("任务被取消:", ctx.Err()) return } }()
<-ctx.Done() // 等待超时或完成
结合 WaitGroup 实现批量任务管理
当需要并发执行多个子任务并统一等待结果时，可将 sync.WaitGroup 与 context 结合使用，确保即使部分任务阻塞也能整体超时退出。
关键点在于每个 worker 都监听同一个 context 的取消信号，避免 WaitGroup 永久阻塞。
- 主流程创建带超时的 context 和 WaitGroup
- 每个 worker 接收 ctx 和 wg，在结束时 Done()
- worker 内部用 select 同时监听业务完成和 ctx 取消
典型结构：
ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second) defer cancel()var wg sync.WaitGroup for i := 0; i < 5; i++ { wg.Add(1) go worker(ctx, &wg, i) }
ch := make(chan struct{}) go func() { wg.Wait() close(ch) }()
select { case <-ch: fmt.Println("所有任务完成") case <-ctx.Done(): fmt.Println("超时，强制退出") }
避免 Goroutine 泄露的注意事项
不当的取消处理会导致 goroutine 无法退出，长期积累造成内存增长甚至程序崩溃。
务必确保：
- 所有基于 context 启动的 goroutine 都响应 ctx.Done()
- 及时调用 cancel 函数释放 context 关联资源
- 不要忽略 ctx.Err() 的判断，尤其是网络 I/O 或锁等待场景
- 慎用 for-select 循环中无 default 分支的结构，防止阻塞 cancel 检测
比如数据库查询、HTTP 请求等外部调用，应传入携带超时的 context，让底层驱动协助中断操作。
总结：合理设计取消边界
实际项目中，超时与取消应根据业务特性设定层级。例如 API 处理链中，入口设置总超时，内部各阶段可设更细粒度限制。
推荐模式：外层 context 控制整体生命周期，内层按需拆分独立 cancel 控制局部任务。配合监控和日志记录取消原因（如 deadline exceeded），有助于问题排查。
基本上就这些，核心是统一使用 context 作为信号枢纽，把“何时停”和“怎么停”变成可预期的行为。
