使用channel和context实现并发信号传递,其中通过无缓冲channel发送完成信号,如done := make(chan struct{}),goroutine执行完任务后关闭通道通知主程序继续。

在Golang中实现并发信号传递,主要依赖于channel和context机制。它们是Go语言处理协程间通信与同步的核心工具。通过合理使用这些机制,可以在多个goroutine之间安全地传递信号,控制执行流程或通知状态变化。
Channel是最基础的信号传递方式,特别适合用于通知某个事件发生,比如任务完成、中断请求等。
无缓冲通道发送信号:
当一个goroutine需要等待另一个goroutine完成某项工作时,可以使用无缓冲channel来接收完成信号。示例:
立即学习“go语言免费学习笔记(深入)”;
done := make(chan struct{})
go func() {
    // 执行一些操作
    defer close(done)
    // ...
}()
// 等待信号
<-done
这里使用struct{}是因为它不占内存空间,仅作为信号标志。
带缓冲channel控制并发数:
通过带缓冲的channel可以限制同时运行的goroutine数量,实现信号量模式。示例:
立即学习“go语言免费学习笔记(深入)”;
semaphore := make(chan struct{}, 3) // 最多3个并发
for i := 0; i < 10; i++ {
    go func(id int) {
        semaphore <- struct{}{} // 获取许可
        defer func() { <-semaphore }() // 释放许可
<pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">    // 执行任务
}(i)}
当需要跨多个goroutine传递取消信号时,context.Context是更合适的选择。它可以优雅地通知所有相关协程停止工作。
示例:
立即学习“go语言免费学习笔记(深入)”;
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
<p>for i := 0; i < 5; i++ {
go func(id int) {
for {
select {
case <-ctx.Done():
fmt.Printf("goroutine %d exiting\n", id)
return
default:
// 执行周期性任务
}
}
}(i)
}</p><p>// 某些条件下触发取消
time.Sleep(2 * time.Second)
cancel() // 发送取消信号
所有监听ctx.Done()的goroutine都会收到信号并退出。
在复杂场景中,可将channel和context结合使用,实现更灵活的信号控制。
例如:等待多个异步任务完成,但整体有超时限制。
ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
defer cancel()
<p>done := make(chan struct{})
go func() {
// 模拟耗时操作
time.Sleep(4 * time.Second)
close(done)
}()</p><p>select {
case <-done:
fmt.Println("任务成功完成")
case <-ctx.Done():
fmt.Println("任务超时或被取消")
}
基本上就这些。channel用于直接信号通知,context用于传播取消和截止时间,两者配合能覆盖大多数并发信号传递需求。关键是根据场景选择合适的机制,避免过度设计。
以上就是如何在Golang中实现并发信号传递的详细内容,更多请关注php中文网其它相关文章!
                        
                        每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
                Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号