本文介绍使用 Go 的 context 包实现竞态式并发控制：启动多个 goroutine 并行获取数据，一旦任一 goroutine 返回结果，立即取消其余协程，避免资源浪费。

本文介绍使用 go 的 `context` 包实现竞态式并发控制：启动多个 goroutine 并行获取数据，一旦任一 goroutine 返回结果，立即取消其余协程，避免资源浪费。

在高并发场景中（如同时查询 Elasticsearch 和 Redis 获取同一份数据），我们常需“取最快者、停其余”的策略——即启动多个 goroutine 并行请求，仅保留首个成功返回的结果，并主动终止仍在运行的其他 goroutine。单纯依赖 channel 无法安全、可靠地实现取消语义；Go 标准库的 context 包为此类协作式取消提供了标准化、可组合且线程安全的解决方案。

✅ 正确做法：使用 context.WithCancel

核心思路是：创建一个可取消的 context，并将其传递给所有参与竞态的 goroutine；当首个结果到达时，调用 cancel() 函数，通知所有监听 ctx.Done() 的 goroutine 立即退出。

以下是一个生产就绪的简化示例：

package main

import (
    "context"
    "fmt"
    "sync"
    "time"
)

func main() {
    // 创建可取消的上下文
    ctx, cancel := context.WithCancel(context.Background())
    defer cancel() // 确保 cleanup（非必须，但推荐）

    // 使用带缓冲的 channel 避免 goroutine 泄漏（防止 cancel 后仍有结果写入）
    data := make(chan string, 2)

    var wg sync.WaitGroup

    // Goroutine A：模拟 ES 查询（较慢）
    wg.Add(1)
    go func() {
        defer wg.Done()
        select {
        case <blockquote><p>? 输出示例：<br>❌ ES query cancelled<br>✅ Got fastest result: Redis: user_123</p></blockquote><h3>⚠️ 关键注意事项</h3>

• 不可仅靠 channel 实现取消：channel 本身不具备“广播取消”能力；若 goroutine 正在阻塞于 I/O 或长时间计算，没有外部信号它无法感知应停止。
• 务必传递 ctx 到下游操作：真实场景中，es.Get() 或 redis.Get() 等方法应接受 context.Context 参数（如 es.Get(ctx, id)），并在内部监听 ctx.Done() 实现底层中断（如 HTTP 请求取消、DB 查询中止）。
• channel 缓冲大小 ≥ goroutine 数量：防止因未及时读取导致 goroutine 卡在发送端（尤其在 cancel 后仍有结果试图写入时）。
• wg.Wait() 应在 cancel() 之后调用：确保所有 goroutine 已响应取消并完成清理，避免程序提前退出。
• 避免重复调用 cancel()：context.CancelFunc 是幂等的，但多次调用无意义，建议只调用一次。

✅ 最佳实践扩展

若需设置超时而非手动取消，可改用 context.WithTimeout(ctx, 500*time.Millisecond)；若需按 deadline 控制，使用 context.WithDeadline。此外，可封装为通用工具函数：

func FirstOf(ctx context.Context, fns ...func(context.Context) (string, error)) (string, error) {
    ch := make(chan result, len(fns))
    var wg sync.WaitGroup

    for _, fn := range fns {
        wg.Add(1)
        go func(f func(context.Context) (string, error)) {
            defer wg.Done()
            val, err := f(ctx)
            ch <p>通过 context 驱动的协作式取消，你不仅能精准控制 goroutine 生命周期，还能与 Go 生态中绝大多数标准库及第三方库（net/http、database/sql、elastic、redis-go 等）无缝集成，真正实现高效、健壮、可维护的并发逻辑。</p>