如何在Golang中实现并发任务取消_Golang context取消机制示例_技术教程

context.WithCancel 是最直接的取消触发方式，返回可取消的 Context 和 cancel 函数，调用后者协作式通知监听 goroutine 退出；必须传入 ctx 并用 select + ctx.Done() 检测取消，避免泄漏和误用。

context.WithCancel 是最直接的取消触发方式

当你需要手动控制一个任务的生命周期，比如用户点击“停止”按钮、超时前主动终止爬虫请求，context.WithCancel 是首选。它返回一个可取消的 context.Context 和一个 cancel 函数，调用后者即向所有监听该 context 的 goroutine 发送取消信号。

关键点在于：取消是**协作式**的，不是强制杀掉 goroutine；每个 goroutine 必须主动检查 ctx.Done() 并退出。

必须在 goroutine 启动前把 ctx 传入，不能在内部重新创建子 context（除非有明确传递链）
cancel() 可被多次调用，但后续调用无实际效果，不会 panic
忘记调用 cancel() 会导致底层 channel 泄漏，尤其在循环中重复创建时要格外小心

ctx, cancel := context.WithCancel(context.Background())
defer cancel() // 防止泄漏，但注意：仅适用于单次使用场景
go func(ctx context.Context) {
for i := 0; i < 10; i++ {
select {
case <-time.After(time.Second):
fmt.Println("working...", i)
case <-ctx.Done():
fmt.Println("cancelled:", ctx.Err()) // context canceled
return
}
}
}(ctx)
time.Sleep(3 * time.Second)
cancel()

select + ctx.Done() 是唯一可靠的取消检测模式

在 goroutine 内部，不能靠轮询 ctx.Err() != nil 来判断是否被取消——这会错过取消瞬间，且浪费 CPU。正确做法永远是用 select 等待 ctx.Done() 这个只读 channel。

ctx.Done() 在 context 被取消或超时时自动关闭，此时 select 分支可立即响应。若 context 未取消，该分支阻塞，不消耗资源。

不要在 select 外单独检查 ctx.Err()，那是无效的“事后补救”
如果 goroutine 正在执行阻塞 IO（如 http.Get），需确保该操作本身支持 context（例如用 http.NewRequestWithContext）
自定义阻塞操作（如数据库查询）必须显式集成 ctx，否则无法响应取消