使用无缓冲channel实现事件通知，主线程等待子任务完成。2. worker函数执行完毕后通过done
在Go语言中，channel 是实现并发通信的核心机制之一。利用 channel 可以轻松构建事件通知系统，让多个 goroutine 之间安全地传递“信号”或“事件”。下面通过一个简单的示例展示如何使用 channel 实现事件通知机制。
使用无缓冲 channel 实现事件通知
当某个事件发生时，发送方通过关闭或写入 channel 通知接收方。接收方阻塞等待，直到收到通知。
例如：主线程等待子任务完成后再继续执行。
使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等
立即学习“go语言免费学习笔记（深入）”；
package main
<p>import (
"fmt"
"time"
)</p><p>func worker(done chan bool) {
fmt.Println("工作开始...")
time.Sleep(2 * time.Second) // 模拟耗时操作
fmt.Println("工作完成")</p><pre class='brush:php;toolbar:false;'>done <- true // 发送完成信号}
func main() { done := make(chan bool)
go worker(done)
fmt.Println("等待工作完成...")
<-done // 阻塞等待通知
fmt.Println("收到完成通知，主程序退出")}
在这个例子中，done channel 用于通知 main 函数 worker 已完成。main 会一直阻塞在
使用 close 关闭 channel 实现广播通知
关闭 channel 也是一种常见的通知方式，尤其适合“完成”或“取消”类事件。所有从已关闭的 channel 读取的 goroutine 都会立即收到零值并解除阻塞。
立即学习“go语言免费学习笔记（深入）”；
func main() {
stop := make(chan struct{})
<pre class='brush:php;toolbar:false;'>go func() {
for {
select {
case <-stop:
fmt.Println("监听器退出")
return
default:
fmt.Println("监听中...")
time.Sleep(500 * time.Millisecond)
}
}
}()
time.Sleep(2 * time.Second)
close(stop) // 发送停止信号
time.Sleep(100 * time.Millisecond) // 等待退出
fmt.Println("主程序结束")}
这里使用 chan struct{} 因为它不携带数据，仅作通知用途，内存开销最小。close(stop) 会唤醒所有等待该 channel 的 select 分支。
多事件源与 select 多路复用
当需要监听多个事件源时，可以结合 select 实现多路事件处理。
立即学习“go语言免费学习笔记（深入）”；
func main() {
sigA := make(chan struct{})
sigB := make(chan struct{})
<pre class='brush:php;toolbar:false;'>go func() {
time.Sleep(1 * time.Second)
sigA <- struct{}{}
}()
go func() {
time.Sleep(3 * time.Second)
sigB <- struct{}{}
}()
for i := 0; i < 2; i++ {
select {
case <-sigA:
fmt.Println("事件 A 到达")
case <-sigB:
fmt.Println("事件 B 到达")
}
}
fmt.Println("所有事件处理完毕")}
select 会随机选择一个就绪的 case 执行，适合处理异步事件流。
基本上就这些。通过 channel + goroutine，Go 能以简洁方式实现高效、安全的事件通知机制，无需锁或复杂状态管理。关键是根据场景选择带缓冲、无缓冲或关闭通知的方式。
