0

0

Golang使用context控制并发任务生命周期

P粉602998670

P粉602998670

发布时间:2025-09-04 08:17:01

|

467人浏览过

|

来源于php中文网

原创

使用context.withcancel可取消goroutine,调用cancel()后所有监听该context的goroutine通过ctx.done()收到信号并退出。

golang使用context控制并发任务生命周期

在Golang中,

context
包提供了一种优雅的方式来管理并发任务的生命周期,包括取消、超时和传递请求相关的值。它允许你构建更健壮、更可控的并发程序。

使用

context
可以控制并发任务的启动、停止和传递请求范围的数据。

如何使用Context取消一个goroutine?

context.WithCancel
函数是实现取消goroutine的关键。它返回一个
context
和一个
CancelFunc
。调用
CancelFunc
会取消
context
,所有监听该
context
的goroutine都会收到取消信号。

package main

import (
    "context"
    "fmt"
    "time"
)

func worker(ctx context.Context, id int) {
    for {
        select {
        case <-ctx.Done():
            fmt.Printf("Worker %d: 任务取消\n", id)
            return
        default:
            fmt.Printf("Worker %d: 正在工作中...\n", id)
            time.Sleep(time.Second)
        }
    }
}

func main() {
    ctx, cancel := context.WithCancel(context.Background())

    // 启动多个worker goroutine
    for i := 1; i <= 3; i++ {
        go worker(ctx, i)
    }

    // 模拟一段时间后取消任务
    time.Sleep(3 * time.Second)
    fmt.Println("准备取消所有worker...")
    cancel()

    // 等待一段时间,确保所有worker都已退出
    time.Sleep(time.Second)
    fmt.Println("所有worker已退出,程序结束")
}

在这个例子中,我们创建了一个带有取消功能的

context
。启动了三个
worker
goroutine,每个goroutine都在循环中执行任务,并监听
context.Done()
通道。当调用
cancel()
函数时,
context
被取消,所有
worker
goroutine收到信号并退出。 我个人觉得这种方式比直接使用channel发送信号更加优雅,尤其是当你需要传递多个取消信号的时候。

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

Context的超时控制是如何实现的?

context.WithTimeout
函数允许你设置一个超时时间。当超过指定时间后,
context
会自动取消。这对于防止goroutine无限期地阻塞非常有用。

Avatar AI
Avatar AI

AI成像模型,可以从你的照片中生成逼真的4K头像

下载
package main

import (
    "context"
    "fmt"
    "time"
)

func longRunningTask(ctx context.Context) {
    select {
    case <-time.After(5 * time.Second):
        fmt.Println("任务完成")
    case <-ctx.Done():
        fmt.Println("任务超时取消")
    }
}

func main() {
    ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
    defer cancel() // 确保即使任务提前完成,cancel也会被调用

    go longRunningTask(ctx)

    select {
    case <-ctx.Done():
        fmt.Println("主程序检测到任务超时")
    case <-time.After(6 * time.Second): // 稍微长于longRunningTask,确保其完成或超时
        fmt.Println("主程序结束")
    }
}

在这个例子中,

longRunningTask
模拟一个需要5秒才能完成的任务。我们使用
context.WithTimeout
设置了3秒的超时时间。如果任务在3秒内没有完成,
context
将被取消,
longRunningTask
会收到取消信号并退出。 注意
defer cancel()
,这是一个好习惯,即使任务提前完成,也应该调用
cancel
释放资源。

如何在Context中传递请求相关的值?

context.WithValue
函数允许你在
context
中存储键值对。这些值可以在goroutine之间传递,例如请求ID、用户信息等。

package main

import (
    "context"
    "fmt"
)

func processRequest(ctx context.Context) {
    userID := ctx.Value("userID")
    fmt.Printf("处理请求,用户ID: %v\n", userID)
}

func main() {
    ctx := context.WithValue(context.Background(), "userID", "12345")
    processRequest(ctx)
}

在这个例子中,我们在

context
中存储了
userID
processRequest
函数可以从
context
中获取
userID
并使用它。 需要注意的是,
context.Value
的键应该是可比较的类型,通常是自定义类型,以避免与其他包冲突。 此外,不要在
context
中传递可选参数,应该使用函数参数来传递。

Context的父子关系是如何工作的?

context
可以有父子关系。子
context
继承父
context
的值、截止时间和取消信号。如果父
context
被取消,所有子
context
也会被取消。

package main

import (
    "context"
    "fmt"
    "time"
)

func childTask(ctx context.Context) {
    select {
    case <-ctx.Done():
        fmt.Println("子任务被取消")
    case <-time.After(2 * time.Second):
        fmt.Println("子任务完成")
    }
}

func main() {
    ctx, cancel := context.WithCancel(context.Background())

    go childTask(ctx)

    time.Sleep(1 * time.Second)
    fmt.Println("取消父任务")
    cancel()

    time.Sleep(1 * time.Second) // 等待子任务退出
}

在这个例子中,

childTask
context
是父
context
的子
context
。当父
context
被取消时,
childTask
也会收到取消信号。 这种父子关系使得你可以构建复杂的并发任务树,并统一管理它们的生命周期。

Context的最佳实践是什么?

  • 始终传递
    context
    作为函数的第一个参数,尤其是当函数会启动goroutine时。
  • 使用
    context.TODO
    作为顶级
    context
    的初始值,表示你还不清楚需要传递什么值。
  • 不要在
    context
    中存储必需的参数,应该使用函数参数来传递。
  • context
    是不可变的,不要修改它。
  • 确保在任务完成后调用
    cancel
    函数,释放资源。
  • 使用自定义类型作为
    context.Value
    的键,避免与其他包冲突。
  • 理解
    context
    的取消和超时机制,并合理地使用它们来管理goroutine的生命周期。

总而言之,

context
是Golang并发编程中一个非常强大的工具。 掌握
context
的使用,可以帮助你构建更健壮、更可控的并发程序。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

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

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

210

2024.02.23

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

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

247

2024.02.23

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

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

356

2024.02.23

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

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

214

2024.03.05

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

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

409

2024.05.21

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

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

490

2025.06.09

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

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

201

2025.06.10

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

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

1438

2025.06.17

C# ASP.NET Core微服务架构与API网关实践
C# ASP.NET Core微服务架构与API网关实践

本专题围绕 C# 在现代后端架构中的微服务实践展开,系统讲解基于 ASP.NET Core 构建可扩展服务体系的核心方法。内容涵盖服务拆分策略、RESTful API 设计、服务间通信、API 网关统一入口管理以及服务治理机制。通过真实项目案例,帮助开发者掌握构建高可用微服务系统的关键技术,提高系统的可扩展性与维护效率。

3

2026.03.11

热门下载

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

精品课程

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

共23课时 | 4.3万人学习

C# 教程
C# 教程

共94课时 | 11.1万人学习

Java 教程
Java 教程

共578课时 | 80.7万人学习

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

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