如何优雅终止竞争型 goroutine 中的未完成任务

本文介绍在 go 中如何通过 context 包实现多个 goroutine 的协同取消机制，避免向已关闭 channel 发送数据导致 panic，并确保资源及时释放、逻辑正确终止。

在 Go 并发编程中，当多个 goroutine 竞争完成同一类任务（如校验、查询、超时等待等），我们通常只需首个完成结果，其余应立即中止——既防止资源浪费，也避免后续误操作（如向已关闭 channel 写入引发 panic）。原始代码试图用 close(ch) 通知“任务结束”，但存在两个根本问题：

1. channel 关闭后无法再发送数据：errEmail 在 errName 已关闭 channel 后仍尝试 ch
2. 关闭 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)

    // 等待任一 g
oroutine 调用 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 非阻塞轮询上下文状态；
• 任一 goroutine 调用 cancel() 后，ctx.Done() channel 立即被关闭，所有监听该 channel 的 select 将立即进入 case
• 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 并发哲学的健壮并发模型。