从多个渠道读取错误

Question

像许多 go 程序员一样，到目前为止都避免对通道做任何重要的事情，所以这个看似简单的场景让我感到难过！我希望多个 goroutines 发送由单亲检查的结果。如果有任何发送错误，父母应该发出信号让他们全部停止。父母应该不按顺序阅读结果。如果其中一个 goroutine 确实发送错误，则此代码有效，即如果您在11内部 nums 中发表评论，否则我们将永远陷入 for 循环。func main() {    type Result struct {        Error    error        Response int    }    checkStatus := func(done <-chan interface{}, ns []int) <-chan Result {        results := make(chan Result)        go func() {            defer close(results)            for _, n := range ns {                result := Result{Response: n}                if n == 11 {                    result.Error = fmt.Errorf("problem...\n")                }                select {                case <-done:                    return                case results <- result:                }            }        }()        return results    }    done := make(chan interface{})    defer close(done)    nums := []int{1, 2, 3, 4, 5 /*11,*/, 6, 7, 8, 9, 10}    c1 := checkStatus(done, nums[:5])    c2 := checkStatus(done, nums[5:])    for {        var r Result        select {        case r = <-c1:            if r.Error != nil {                fmt.Printf("error1: %v", r.Error)                return            }            fmt.Printf("Response1: %v\n", r.Response)        case r = <-c2:            if r.Error != nil {                fmt.Printf("error2: %v", r.Error)                return            }            fmt.Printf("Response2: %v\n", r.Response)        }    }}我能看到修复它的唯一方法是更改for循环，以便它从中读取c1，c2但我看不到非顺序执行此操作的方法？https://go.dev/play/p/7dRPMDn1Za2

Answer 1

您正在从封闭的渠道中阅读，他们总是返回零值。您可以做的是在从通道读取时使用逗号 ok 习惯用法关闭选择案例，然后将通道分配给 nil。如果另一个也为零，则返回。

case使用 nil 通道永远不会运行。

只需扩展您的代码（与 的情况类似c2）：

case r, ok := <-c1:

    if !ok {

        c1 = nil

        if c2 == nil {

            return

        }

        continue

    }

    if r.Error != nil {

        fmt.Printf("error1: %v", r.Error)

        return

    }

    fmt.Printf("Response1: %v\n", r.Response)

但我宁愿尝试重构整个实现。

您可以考虑使用sync.WaitGroup来自syncpkg 或errgroup.Group来自errgrouppkg.