0

0

如何在Golang中实现并发任务取消_Golang context取消机制示例

P粉602998670

P粉602998670

发布时间:2025-12-31 17:12:08

|

242人浏览过

|

来源于php中文网

原创

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

如何在golang中实现并发任务取消_golang context取消机制示例

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 未取消,该分支阻塞,不消耗资源。

立即学习go语言免费学习笔记(深入)”;

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

context.WithTimeout 和 context.WithDeadline 本质相同,但语义不同

context.WithTimeout(ctx, 2*time.Second)context.WithDeadline(ctx, time.Now().Add(2*time.Second)) 最终行为一致:都会在约 2 秒后触发取消。区别在于可读性与适用场景:

知了追踪
知了追踪

AI智能信息助手,智能追踪你的兴趣资讯

下载
  • WithTimeout 更适合“最多运行 N 秒”的逻辑,比如 API 请求最大等待时间
  • WithDeadline 更适合“必须在某个绝对时间点前完成”,比如和外部系统约定截止时刻
  • 两者都依赖系统时钟,若机器时间被大幅调整(如 NTP 校正),WithDeadline 可能提前或延后触发

注意:timeout 是相对当前时间的偏移量,不是从 goroutine 启动开始计时——它从 WithTimeout 调用那一刻起算。

子 context 的取消会自动传播到所有后代

Go 的 context 取消是树状传播的:父 context 被取消,所有通过 WithCancel/WithTimeout/WithDeadline 创建的子 context 也会同时被取消,无需手动管理层级。

但要注意:子 context 的取消**不会反向影响父 context**。也就是说,你可以在一个长生命周期的 context 上派生多个短期任务,各自独立取消,互不干扰。

  • 避免把同一个 cancel 函数到处传递并多次调用,容易引发竞态或误取消
  • HTTP handler 中常用 r.Context() 作为根 context,再派生带 timeout 的子 context 用于下游调用
  • 数据库连接池、日志上下文等中间件应始终接收并透传 context,否则取消信号会在某一层断掉

真正难的不是写对那几行 select,而是确保整个调用链路每一层都尊重 ctx —— 少一个 select,就少一处取消入口。

相关专题

更多
golang如何定义变量
golang如何定义变量

golang定义变量的方法:1、声明变量并赋予初始值“var age int =值”;2、声明变量但不赋初始值“var age int”;3、使用短变量声明“age :=值”等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

174

2024.02.23

golang有哪些数据转换方法
golang有哪些数据转换方法

golang数据转换方法:1、类型转换操作符;2、类型断言;3、字符串和数字之间的转换;4、JSON序列化和反序列化;5、使用标准库进行数据转换;6、使用第三方库进行数据转换;7、自定义数据转换函数。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

224

2024.02.23

golang常用库有哪些
golang常用库有哪些

golang常用库有:1、标准库;2、字符串处理库;3、网络库;4、加密库;5、压缩库;6、xml和json解析库;7、日期和时间库;8、数据库操作库;9、文件操作库;10、图像处理库。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

335

2024.02.23

golang和python的区别是什么
golang和python的区别是什么

golang和python的区别是:1、golang是一种编译型语言,而python是一种解释型语言;2、golang天生支持并发编程,而python对并发与并行的支持相对较弱等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

206

2024.03.05

golang是免费的吗
golang是免费的吗

golang是免费的。golang是google开发的一种静态强类型、编译型、并发型,并具有垃圾回收功能的开源编程语言,采用bsd开源协议。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

388

2024.05.21

golang结构体相关大全
golang结构体相关大全

本专题整合了golang结构体相关大全,想了解更多内容,请阅读专题下面的文章。

193

2025.06.09

golang相关判断方法
golang相关判断方法

本专题整合了golang相关判断方法,想了解更详细的相关内容,请阅读下面的文章。

188

2025.06.10

golang数组使用方法
golang数组使用方法

本专题整合了golang数组用法,想了解更多的相关内容,请阅读专题下面的文章。

191

2025.06.17

php源码安装教程大全
php源码安装教程大全

本专题整合了php源码安装教程,阅读专题下面的文章了解更多详细内容。

3

2025.12.31

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Go 教程
Go 教程

共32课时 | 3.1万人学习

Go语言实战之 GraphQL
Go语言实战之 GraphQL

共10课时 | 0.8万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号