使用无缓冲channel实现事件通知，主线程等待子任务完成。2. worker函数执行完毕后通过done
在Go语言中，channel 是实现并发通信的核心机制之一。利用 channel 可以轻松构建事件通知系统，让多个 goroutine 之间安全地传递“信号”或“事件”。下面通过一个简单的示例展示如何使用 channel 实现事件通知机制。
使用无缓冲 channel 实现事件通知
当某个事件发生时，发送方通过关闭或写入 channel 通知接收方。接收方阻塞等待，直到收到通知。
例如：主线程等待子任务完成后再继续执行。
中国最实用的办公自动化系统，全面提升单位的工作效率和质量，整合企业资源，规范办公流程，加快信息流通，提高办公效率，降低办公成本，通过提高执行力来完善管理，从而提升企业竞争力 含公告通知、文件传送、电子通讯薄、日程安排、工作日记、工作计划、个人（公共）文件柜、网上申请和审批、电子邮件、手机短信、个人考勤、知识管理、人事管理、车辆管理、会议管理、印信管理、网上填报、规章制度、论坛、网络会议、语音聊天、
立即学习“go语言免费学习笔记（深入）”；
package mainimport ( "fmt" "time" )
func worker(done chan bool) { fmt.Println("工作开始...") time.Sleep(2 * time.Second) // 模拟耗时操作 fmt.Println("工作完成")
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{})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{})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 能以简洁方式实现高效、安全的事件通知机制，无需锁或复杂状态管理。关键是根据场景选择带缓冲、无缓冲或关闭通知的方式。
