读取错误在多通道中发生

小伙伴们有没有觉得学习Golang很有意思？有意思就对了！今天就给大家带来《读取错误在多通道中发生》，以下内容将会涉及到，若是在学习中对其中部分知识点有疑问，或许看了本文就能帮到你！

像许多 go 程序员一样，到目前为止，还避免对通道做任何重要的事情，所以这个看似简单的场景让我难住了！

我想要多个 goroutine 发送由单个父级检查的结果。如果有任何人发送错误，家长应发出信号让他们全部停止。家长应不按顺序读取结果。

如果其中一个 goroutine 确实发送错误，即如果您在 nums 内的 11 中进行注释，则此代码可以工作，否则我们将永远陷入 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

正确答案

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

带有 nil 通道的 case 永远不会运行。

只需扩展您的代码（与 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 pkg 中的 sync.waitgroup 或 errgroup.group 来自 errgroup pkg。

终于介绍完啦！小伙伴们，这篇关于《读取错误在多通道中发生》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！