登录
首页 >  Golang >  Go教程

Golangchannel事件通知实现教程

时间:2025-11-14 13:07:29 462浏览 收藏

今日不肯埋头,明日何以抬头!每日一句努力自己的话哈哈~哈喽,今天我将给大家带来一篇《Golang channel事件通知实现示例》,主要内容是讲解等等,感兴趣的朋友可以收藏或者有更好的建议在评论提出,我都会认真看的!大家一起进步,一起学习!

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

Golangchannel实现事件通知机制示例

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

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

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

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

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 都会立即收到零值并解除阻塞。

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

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

到这里,我们也就讲完了《Golangchannel事件通知实现教程》的内容了。个人认为,基础知识的学习和巩固,是为了更好的将其运用到项目中,欢迎关注golang学习网公众号,带你了解更多关于的知识点!

相关阅读
更多>
最新阅读
更多>
课程推荐
更多>