go - 从 goroutine 获取值并取消另一个 goroutine

Question

我有一个案例，我从 2 个不同的位置(ES 和 REDIS)读取数据，我需要从最快的源读取一个值，因此我触发了 2 个 goroutines，一个从 ES 获取数据，其他从REDIS获取。

一旦从其中一个 goroutine 获取了数据，就必须完全取消另一个 goroutine，以免浪费 CPU。

简化:

func A(){
    go funcB(){

    }()

    go funcC(){

    }()

    data := <-channel // 
}

现在一旦接收到数据，funcA 或 funcB 必须取消，无论它们在做什么(我不再关心它们的输出，它们是只是在浪费 CPU)

最有效的方法是什么？可以仅使用 channel 来完成吗？

Answer 1

context package为此提供取消、超时和截止日期上下文。在这里你可以看到一个取消的例子，我们等待较慢的 goroutine 打印取消的消息:

ctx, cancel := context.WithCancel(context.Background())

// buffer the channel for extra results returned before cancelation
data := make(chan string, 2)

var wg sync.WaitGroup
wg.Add(1)
go func() {
    defer wg.Done()
    select {
    case <-time.After(100 * time.Millisecond):
        data <- "A complete"
    case <-ctx.Done():
        fmt.Println("A cancelled")
    }
}()

wg.Add(1)
go func() {
    defer wg.Done()
    select {
    case <-time.After(200 * time.Millisecond):
        data <- "B complete"
    case <-ctx.Done():
        fmt.Println("B cancelled")
    }
}()

resp := <-data
cancel()
fmt.Println(resp)
wg.Wait()

https://play.golang.org/p/vAhksjKozW