Golang如何实现异步通知机制_Golang异步通知与Goroutine通信实践

done := make(chan struct{})
<p>go func() {
// 模拟耗时操作
time.Sleep(2 * time.Second)
close(done) // 通知已完成
}()</p><p>// 主协程等待通知
<-done
fmt.Println("任务完成")</p>

type Result struct {
    Data string
    Err  error
}
<p>results := make(chan Result, 3)</p>
                    <div class="aritcle_card">
                        <a class="aritcle_card_img" href="/ai/926">
                            <img src="https://img.php.cn/upload/ai_manual/001/503/042/68b6d2df4c212213.png" alt="STORYD">
                        </a>
                        <div class="aritcle_card_info">
                            <a href="/ai/926">STORYD</a>
                            <p>帮你写出让领导满意的精美文稿</p>
                            <div class="">
                                <img src="/static/images/card_xiazai.png" alt="STORYD">
                                <span>164</span>
                            </div>
                        </div>
                        <a href="/ai/926" class="aritcle_card_btn">
                            <span>查看详情</span>
                            <img src="/static/images/cardxiayige-3.png" alt="STORYD">
                        </a>
                    </div>
                <p>for i := 0; i < 3; i++ {
go func(id int) {
// 模拟处理
time.Sleep(time.Duration(rand.Intn(1000)) * time.Millisecond)
results <- Result{Data: fmt.Sprintf("任务%d完成", id)}
}(i)
}</p><p>// 等待所有任务完成
for i := 0; i < 3; i++ {
result := <-results
fmt.Println(result.Data)
}</p>

select {
case <-done:
    fmt.Println("任务正常完成")
case <-time.After(3 * time.Second):
    fmt.Println("任务超时")
}

var once sync.Once
shutdown := make(chan struct{})
<p>go func() {
once.Do(func() {
close(shutdown)
})
}()</p>