本文介绍在 go 中如何通过 context 包实现多个 goroutine 的协同取消机制，避免向已关闭 channel 发送数据导致 panic，并确保资源及时释放、逻辑正确终止。
在 Go 并发编程中，当多个 goroutine 竞争完成同一类任务（如校验、查询、超时等待等），我们通常只需首个完成结果，其余应立即中止——既防止资源浪费，也避免后续误操作（如向已关闭 channel 写入引发 panic）。原始代码试图用 close(ch) 通知“任务结束”，但存在两个根本问题：
- channel 关闭后无法再发送数据：errEmail 在 errName 已关闭 channel 后仍尝试 ch <- ...，直接触发 panic: send on closed channel；
- 关闭 channel 不等于终止 goroutine：close(ch) 仅影响 channel 通信状态，对正在运行的 goroutine 无任何控制力，其后续逻辑（包括循环）仍会继续执行。
✅ 正确解法是使用 context.Context ——Go 官方推荐的跨 goroutine 传递取消信号、截止时间与请求范围值的标准机制。
✅ 推荐实现：基于 context.WithCancel 的协作式取消
package main
import (
"fmt"
"time"
"context" // Go 1.7+ 内置，无需额外安装
)
func errName(ctx context.Context, cancel context.CancelFunc) {
for i := 0; i < 10000; i++ {
select {
case <-ctx.Done(): // 检查是否已被取消
fmt.Println("errName cancelled")
return
default:
}
// 模拟工作（可替换为实际业务逻辑）
time.Sleep(1 * time.Microsecond)
}
fmt.Println("errName completed successfully")
cancel() // 主动触发取消，通知其他 goroutine
}
func errEmail(ctx context.Context, cancel context.CancelFunc) {
for i := 0; i < 100; i++ {
select {
case <-ctx.Done():
fmt.Println("errEmail cancelled")
return
default:
}
time.Sleep(1 * time.Microsecond)
}
fmt.Println("errEmail completed successfully")
cancel()
}
func main() {
ctx := context.Background()
ctx, cancel := context.WithCancel(ctx)
defer cancel() // 确保退出前清理（非必须，但属良好实践）
go errName(ctx, cancel)
go errEmail(ctx, cancel)
// 等待任一 goroutine 调用 cancel()，或 ctx 被显式取消
<-ctx.Done()
// 输出取消原因（如被 cancel 或超时）
if err := ctx.Err(); err != nil {
fmt.Printf("Context cancelled: %v\n", err)
}
// 给 goroutine 留出足够时间打印日志（生产环境建议用 sync.WaitGroup）
time.Sleep(100 * time.Millisecond)
}? 关键原理说明
- context.WithCancel() 返回一个可取消的 ctx 和对应的 cancel() 函数；
- 所有 goroutine 通过 select { case <-ctx.Done(): ... } 非阻塞轮询上下文状态；
- 任一 goroutine 调用 cancel() 后，ctx.Done() channel 立即被关闭，所有监听该 channel 的 select 将立即进入 case <-ctx.Done() 分支并返回，实现快速退出；
- ctx.Err() 可获取取消原因（context.Canceled 或 context.DeadlineExceeded），便于日志与诊断。
⚠️ 注意事项
- ❌ 不要混用 channel 关闭与 context 取消：二者语义不同（channel 关闭 = 通信结束；context 取消 = 生命周期终止）；
- ✅ 始终在 select 中检查 ctx.Done()，尤其在循环、I/O 或长耗时操作前后；
- ✅ 若需传递错误信息，可配合 chan error + context 使用（例如主 goroutine 从 channel 收结果，同时监听 ctx.Done() 防止阻塞）；
- ✅ 生产环境中，建议用 sync.WaitGroup 替代 time.Sleep 精确等待 goroutine 退出。
通过 context 实现的取消机制，不仅解决了原始 panic 问题，更构建了可组合、可测试、符合 Go 并发哲学的健壮并发模型。
