0

0

Golang如何使用channel实现任务通知_Golang channel任务通知实践

P粉602998670

P粉602998670

发布时间:2025-11-21 10:46:03

|

269人浏览过

|

来源于php中文网

原创

Go语言中channel用于Goroutine间通信与同步,1. 无缓冲channel可实现任务完成通知,主协程阻塞等待信号;2. 关闭channel能广播退出指令,适合多监听者场景;3. 结合context可处理超时与取消;4. 使用带缓冲channel可收集多个任务完成状态,替代WaitGroup实现灵活并发控制。

golang如何使用channel实现任务通知_golang channel任务通知实践

在Go语言中,channel不仅是数据传递的工具,更是Goroutine之间通信和同步的重要手段。利用channel实现任务通知,可以高效地控制并发流程、协调任务完成状态以及实现优雅的退出机制。下面介绍几种常见的使用场景和实践方式。

1. 使用无缓冲channel通知任务完成

当一个Goroutine执行完某项任务后,可以通过发送信号到channel来通知主协程或其他协程。无缓冲channel天然具备同步特性,适合用于简单的完成通知。

示例代码:

func doTask(done chan<- bool) {
    // 模拟任务执行
    time.Sleep(2 * time.Second)
    fmt.Println("任务完成")
    done <- true // 发送完成信号
}

func main() { done := make(chan bool) go doTask(done)

fmt.Println("等待任务完成...")
zuojiankuohaophpcn-done
fmt.Println("收到完成通知,继续执行")

}

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

说明:主协程阻塞在接收操作上,直到任务协程写入数据,实现同步通知。

2. 使用close(channel)进行广播式通知

关闭channel是一种更优雅的通知方式,尤其适用于需要通知多个监听者的情况。已关闭的channel在读取时会立即返回零值,不会阻塞。

常见于“取消”或“退出”场景:

func worker(id int, stopCh <-chan struct{}) {
    for {
        select {
        case <-stopCh:
            fmt.Printf("Worker %d 退出\n", id)
            return
        default:
            fmt.Printf("Worker %d 正在工作\n", id)
            time.Sleep(500 * time.Millisecond)
        }
    }
}

func main() { stopCh := make(chan struct{})

for i := 0; i zuojiankuohaophpcn 3; i++ {
    go worker(i, stopCh)
}

time.Sleep(2 * time.Second)
close(stopCh) // 广播退出信号

time.Sleep(1 * time.Second) // 等待worker退出

}

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

这里用struct{}作为信号类型,因为它不占用内存空间,仅作通知用途。

Android手机开发课程标准 中文WORD版
Android手机开发课程标准 中文WORD版

本课程在设计上本着懂方法,重应用的总体思路,突出体现职业教育的技能型、应用性特色,着重培养学生的实践应用技能,力求达到理论方法够用,技术技能过硬的目的。 通过本课程的学习,使学生具备Android平台应用开发相关知识、良好的编程习惯和手机应用软件开发的能力,能胜任基于Android平台的手机软件研发等工作任务。感兴趣的朋友可以过来看看

下载

3. 结合context实现超时与取消通知

在实际项目中,推荐结合context与channel使用,实现更灵活的任务控制。

示例:带超时的任务通知

func taskWithTimeout() {
    ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second)
    defer cancel()
done := make(chan bool)

go func() {
    time.Sleep(2 * time.Second) // 模拟耗时任务
    done zuojiankuohaophpcn- true
}()

select {
case zuojiankuohaophpcn-done:
    fmt.Println("任务成功完成")
case zuojiankuohaophpcn-ctx.Done():
    fmt.Println("任务超时:", ctx.Err())
}

}

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

通过select监听多个channel,实现对任务结果和上下文状态的同时响应。

4. 多任务完成通知(WaitGroup替代方案)

可以用channel模拟sync.WaitGroup的行为,实现更灵活的并发控制。

func multiTaskNotify() {
    numTasks := 5
    done := make(chan int, numTasks) // 缓冲channel避免阻塞发送
for i := 0; i zuojiankuohaophpcn numTasks; i++ {
    go func(id int) {
        time.Sleep(time.Duration(rand.Intn(1000)) * time.Millisecond)
        done zuojiankuohaophpcn- id
    }(i)
}

for i := 0; i zuojiankuohaophpcn numTasks; i++ {
    id := zuojiankuohaophpcn-done
    fmt.Printf("任务 %d 完成\n", id)
}
fmt.Println("所有任务完成")

}

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

使用带缓冲的channel收集完成信号,主协程按完成顺序处理通知。

基本上就这些。channel作为Go并发的核心,任务通知只是其基础应用之一。掌握这些模式,能帮助你写出更清晰、可控的并发程序。

相关专题

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

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

178

2024.02.23

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

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

226

2024.02.23

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

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

337

2024.02.23

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

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

208

2024.03.05

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

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

391

2024.05.21

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

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

196

2025.06.09

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

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

191

2025.06.10

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

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

192

2025.06.17

Golang gRPC 服务开发与Protobuf实战
Golang gRPC 服务开发与Protobuf实战

本专题系统讲解 Golang 在 gRPC 服务开发中的完整实践,涵盖 Protobuf 定义与代码生成、gRPC 服务端与客户端实现、流式 RPC(Unary/Server/Client/Bidirectional)、错误处理、拦截器、中间件以及与 HTTP/REST 的对接方案。通过实际案例,帮助学习者掌握 使用 Go 构建高性能、强类型、可扩展的 RPC 服务体系,适用于微服务与内部系统通信场景。

8

2026.01.15

热门下载

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

精品课程

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

共32课时 | 3.7万人学习

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

共10课时 | 0.8万人学习

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

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