Golang channel事件通知实现示例

使用无缓冲channel实现事件通知，主线程等待子任务完成。2. worker函数执行完毕后通过done<-true发送信号，main函数接收信号后继续执行，实现goroutine间同步。

在Go语言中，channel 是实现并发通信的核心机制之一。利用 channel 可以轻松构建事件通知系统，让多个 goroutine 之间安全地传递“信号”或“事件”。下面通过一个简单的示例展示如何使用 channel 实现事件通知机制。

使用无缓冲 channel 实现事件通知

当某个事件发生时，发送方通过关闭或写入 channel 通知接收方。接收方阻塞等待，直到收到通知。

例如：主线程等待子任务完成后再继续执行。

package main
import (
"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 会一直阻塞在 <-done，直到 worker 写入数据。

使用 close 关闭 channel 实现广播通知

关闭 channel 也是一种常见的通知方式，尤其适合“完成”或“取消”类事件。所有从已关闭的 channel 读取的 goroutine 都会立即收到零值并解除阻塞。

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 实现多路事件处理。

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 能以简洁方式实现高效、安全的事件通知机制，无需锁或复杂状态管理。关键是根据场景选择带缓冲、无缓冲或关闭通知的方式。