17370845950

Go中超时任务取消需用context.WithTimeout监听ctx.Done()，配合defer cancel()防泄漏；标准库操作如HTTP、SQL原生支持context；子协程和资源需手动清理，不可忽略ctx.Err()或用time.Sleep替代select。

在 Go 中实现超时任务取消，核心是使用 context 包配合 time.AfterFunc 或 context.WithTimeout，让协程能感知取消信号并主动退出，避免 goroutine 泄漏。

用 context.WithTimeout 启动带超时的协程

这是最常用的方式：创建一个带超时的 context，将其传入协程，在协程内部持续监听 ctx.Done()。一旦超时，ctx.Err() 会返回 context.DeadlineExceeded，协程应立即清理并返回。

示例：

ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
defer cancel() // 避免 context 泄漏
go func(ctx context.Context) {
for i := 0; i < 10; i++ {
select {
case <-time.After(1 * time.Second):
fmt.Printf("第 %d 次执行\n", i+1)
case <-ctx.Done():
fmt.Println("任务被取消：", ctx.Err())
return
}
}
}(ctx)

在阻塞操作中响应取消（如 HTTP 请求、数据库查询）

很多标准库函数（如 http.Client.Do、database/sql.QueryContext）原生支持 context。直接传入可取消的 context，它们会在超时或取消时自动中断操作并返回错误。

立即学习“go语言免费学习笔记（深入）”；

• HTTP 请求：用 http.NewRequestWithContext 构造请求，再由 client 发起
• SQL 查询：用 db.QueryContext(ctx, sql) 替代 db.Query
• 文件读取/写入：对支持 io.Reader 或 io.Writer 的封装类型，可结合 io.Copy + ctx.Done() 做手动中断（需额外逻辑）

手动传播 cancel 并清理资源

如果协程启动了子协程，或持有文件句柄、网络连接等资源，不能只靠 select 监听 Done() 就结束。必须在退出前显式关闭资源、调用 cancel()（若自己创建了子 context）、等待子协程退出。

关键点：

• 始终调用 defer cancel()（除非你明确要传递 cancel 函数给下游）
• 子协程也应接收 context，并在完成时通知父协程（例如通过 channel 或 sync.WaitGroup）
• 不要忽略 ctx.Err()，它告诉你为何退出（超时 / 取消 / 取消原因）

避免常见陷阱

context 不会强制杀死 goroutine，它只是“通知”——是否响应，完全取决于你的代码有没有监听 ctx.Done() 并做处理。

• ❌ 错误：启动 goroutine 后不传 context，或传了但没监听 Done()
• ❌ 错误：用 time.Sleep 替代 select + time.After，导致无法及时响应取消
• ❌ 错误：忘记调用 cancel()，造成 context 和其关联 timer 泄漏
• ✅ 正确：所有可能长时间运行的逻辑都包裹在 select 中，至少包含 case

不复杂但容易忽略。关键是把 context 当作“生命信号”贯穿整个调用链，每一层都检查、传递、响应。