使用无缓冲channel可实现goroutine间同步通知，如后台任务完成后通过done通道通知主流程继续执行。
在Go语言中，channel 不仅是协程间通信的核心机制，也是实现事件通知的自然选择。利用 channel 可以轻松地在不同 goroutine 之间传递“信号”或“状态变更”，从而实现高效的事件驱动逻辑。以下是几种常见的使用 channel 实现事件通知的实践方法。
1. 使用无缓冲 channel 进行同步通知
当一个 goroutine 需要等待另一个 goroutine 完成某项任务时，可以使用无缓冲 channel 发送完成信号。
这种模式常用于启动后台服务后通知主流程继续执行。
func main() {done := make(chan bool)
go func() {
// 模拟耗时操作
time.Sleep(2 * time.Second)
fmt.Println("任务完成")
done }()
fmt.Println("等待任务...")
fmt.Println("收到完成信号")
}
2. 使用 close(channel) 触发广播通知
关闭 channel 会触发所有从该 channel 接收的 goroutine 立即解除阻塞，适合用于“取消”或“终止”类事件的广播。
立即学习“go语言免费学习笔记（深入）”；
一旦 channel 被关闭，所有接收操作都会立即返回零值，并且 ok 值为 false。
func worker(id int, stopCh for {
select {
case 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 go worker(i, stopCh)
}
time.Sleep(2 * time.Second)
close(stopCh) // 广播停止信号
time.Sleep(1 * time.Second) // 等待 workers 结束
}
3. 多事件类型通过 channel 传递结构体
当需要通知不同类型的事件时，可以用带结构体的 channel 来传递事件数据。
这种方式适用于状态更新、用户登录、系统告警等复杂场景。
type Event struct {Type string
Data interface{}
}
func eventHandler(eventCh for event := range eventCh {
switch event.Type {
case "user_login":
fmt.Printf("用户登录: %s\n", event.Data)
case "error":
fmt.Printf("发生错误: %v\n", event.Data)
}
}
}
func main() {
eventCh := make(chan Event, 10)
go eventHandler(eventCh)
eventCh eventCh
close(eventCh)
time.Sleep(500 * time.Millisecond)
}
4. 结合 context 与 channel 实现超时控制
虽然 context 是官方推荐的取消机制，但其底层仍是基于 channel 的通知。我们可以手动模拟类似行为，或混合使用。
例如：用 time.After 或自定义定时器结合 select 实现超时事件。
func waitForSignal(timeout time.Duration) bool {signal := make(chan bool)
go func() {
// 模拟某些条件满足后发送信号
time.Sleep(3 * time.Second)
signal }()
select {
case return true
case fmt.Println("等待超时")
return false
}
}
基本上就这些。通过合理设计 channel 类型和使用 select、close、struct{} 等技巧，可以在 Go 中构建灵活可靠的事件通知系统。关键在于明确事件语义，避免 goroutine 泄漏，确保 channel 被正确关闭或监听。
