如何在Golang中实现并发信号传递

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

在Golang中实现并发信号传递，主要依赖于channel和context机制。它们是Go语言处理协程间通信与同步的核心工具。通过合理使用这些机制，可以在多个goroutine之间安全地传递信号，控制执行流程或通知状态变化。

使用Channel进行信号传递

Channel是最基础的信号传递方式，特别适合用于通知某个事件发生，比如任务完成、中断请求等。

无缓冲通道发送信号：

示例：

立即学习“go语言免费学习笔记（深入）”；

ChatX翻译

最实用、可靠的社交类实时翻译工具。 支持全球主流的20+款社交软件的聊天应用，全球200+语言随意切换。 让您彻底告别复制粘贴的翻译模式，与世界各地高效连接！

下载

done := make(chan struct{})
go func() {
    // 执行一些操作
    defer close(done)
    // ...
}()
// 等待信号
<-done

这里使用struct{}是因为它不占内存空间，仅作为信号标志。

带缓冲channel控制并发数：

示例：

立即学习“go语言免费学习笔记（深入）”；

semaphore := make(chan struct{}, 3) // 最多3个并发
for i := 0; i < 10; i++ {
    go func(id int) {
        semaphore <- struct{}{} // 获取许可
        defer func() { <-semaphore }() // 释放许可
    // 执行任务
}(i)
}

结合Context取消信号
当需要跨多个goroutine传递取消信号时，context.Context是更合适的选择。它可以优雅地通知所有相关协程停止工作。
示例：
立即学习“go语言免费学习笔记（深入）”；
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
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)
}
// 某些条件下触发取消
time.Sleep(2 * time.Second)
cancel() // 发送取消信号
所有监听ctx.Done()的goroutine都会收到信号并退出。
组合使用Channel与Context
在复杂场景中，可将channel和context结合使用，实现更灵活的信号控制。
例如：等待多个异步任务完成，但整体有超时限制。
ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
defer cancel()
done := make(chan struct{})
go func() {
// 模拟耗时操作
time.Sleep(4 * time.Second)
close(done)
}()
select {
case <-done:
fmt.Println("任务成功完成")
case <-ctx.Done():
fmt.Println("任务超时或被取消")
}
基本上就这些。channel用于直接信号通知，context用于传播取消和截止时间，两者配合能覆盖大多数并发信号传递需求。关键是根据场景选择合适的机制，避免过度设计。