Go语言中channel用于Goroutine间通信与同步，1. 无缓冲channel可实现任务完成通知，主协程阻塞等待信号；2. 关闭channel能广播退出指令，适合多监听者场景；3. 结合context可处理超时与取消；4. 使用带缓冲channel可收集多个任务完成状态，替代WaitGroup实现灵活并发控制。
在Go语言中，channel不仅是数据传递的工具，更是Goroutine之间通信和同步的重要手段。利用channel实现任务通知，可以高效地控制并发流程、协调任务完成状态以及实现优雅的退出机制。下面介绍几种常见的使用场景和实践方式。
1. 使用无缓冲channel通知任务完成
当一个Goroutine执行完某项任务后，可以通过发送信号到channel来通知主协程或其他协程。无缓冲channel天然具备同步特性，适合用于简单的完成通知。
示例代码：
func doTask(done chan<- bool) {
// 模拟任务执行
time.Sleep(2 * time.Second)
fmt.Println("任务完成")
done <- true // 发送完成信号
}
<p>func main() {
done := make(chan bool)
go doTask(done)</p><pre class='brush:php;toolbar:false;'>fmt.Println("等待任务完成...")
<-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)
}
}
}
<p>func main() {
stopCh := make(chan struct{})</p><pre class='brush:php;toolbar:false;'>for i := 0; i < 3; i++ {
go worker(i, stopCh)
}
time.Sleep(2 * time.Second)
close(stopCh) // 广播退出信号
time.Sleep(1 * time.Second) // 等待worker退出}
立即学习“go语言免费学习笔记（深入）”；
这里用struct{}作为信号类型，因为它不占用内存空间，仅作通知用途。
使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等
3. 结合context实现超时与取消通知
在实际项目中，推荐结合context与channel使用，实现更灵活的任务控制。
示例：带超时的任务通知
func taskWithTimeout() {
ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second)
defer cancel()
<pre class='brush:php;toolbar:false;'>done := make(chan bool)
go func() {
time.Sleep(2 * time.Second) // 模拟耗时任务
done <- true
}()
select {
case <-done:
fmt.Println("任务成功完成")
case <-ctx.Done():
fmt.Println("任务超时:", ctx.Err())
}}
立即学习“go语言免费学习笔记（深入）”；
通过select监听多个channel，实现对任务结果和上下文状态的同时响应。
4. 多任务完成通知（WaitGroup替代方案）
可以用channel模拟sync.WaitGroup的行为，实现更灵活的并发控制。
func multiTaskNotify() {
numTasks := 5
done := make(chan int, numTasks) // 缓冲channel避免阻塞发送
<pre class='brush:php;toolbar:false;'>for i := 0; i < numTasks; i++ {
go func(id int) {
time.Sleep(time.Duration(rand.Intn(1000)) * time.Millisecond)
done <- id
}(i)
}
for i := 0; i < numTasks; i++ {
id := <-done
fmt.Printf("任务 %d 完成\n", id)
}
fmt.Println("所有任务完成")}
立即学习“go语言免费学习笔记（深入）”；
使用带缓冲的channel收集完成信号，主协程按完成顺序处理通知。
基本上就这些。channel作为Go并发的核心，任务通知只是其基础应用之一。掌握这些模式，能帮助你写出更清晰、可控的并发程序。
