从循环中收集嵌套的 goroutine 错误

积累知识，胜过积蓄金银！毕竟在Golang开发的过程中，会遇到各种各样的问题，往往都是一些细节知识点还没有掌握好而导致的，因此基础知识点的积累是很重要的。下面本文《从循环中收集嵌套的 goroutine 错误》，就带大家讲解一下知识点，若是你对本文感兴趣，或者是想搞懂其中某个知识点，就请你继续往下看吧~

我正在尝试从循环中的 goroutine 收集错误，但不明白它必须如何正确工作 https://go.dev/play/p/wrxe0vh6jsg

func init() {
    rand.Seed(1500929006430687579)
}

func goroutine(n int, wg *sync.WaitGroup, ch chan error) {
    defer wg.Done()
    defer fmt.Println("defer done")

    fmt.Println("num ", n)
    if n == 1 {
        ch <- fmt.Errorf("error")
    } else {
        ch <- nil
    }
}

func main() {
    var wg sync.WaitGroup
    var err error
    errs := make(chan error)
    platforms := 2
    types := 3
    for j := 0; j < platforms; j++ {
        wg.Add(1)
        for k := 0; k < types; k++ {
            wg.Add(1)
            n := rand.Intn(2)
            go goroutine(n, &wg, errs)
        }

        for k := 0; k < types; k++ {
            wg.Add(1)
            n := rand.Intn(2)
            go goroutine(n, &wg, errs)
        }
    }
    wg.Wait()
    err = <-errs
    fmt.Println(err)
}

我应该如何正确收集错误数组并完成所有等待组？

正确答案

golang 中的通道类似于 bash 中的管道 (|)。但与用于将一个命令的输出传输到另一命令的输入的 bash 管道不同，go 通道用于在 goroutine 之间传输一些数据。您可以阅读更多有关频道 here 的信息。 渠道有容量。当您没有指定通道的容量时，go 会假设它的容量为 0。零容量的通道通常称为 unbuffered 通道，而非零容量的通道称为 buffered。当通道已满（通道中的元素数量等于通道容量）时，通道上的所有写操作（->errs）都会阻塞执行流程，直到出现读操作（<-errs）为止。

在您的特定示例中，您有无缓冲的通道（容量为 0 的通道）。因此，通道上的任何写入操作 (->errs) 都会阻塞执行，直到提供某些读取操作为止，因此，尽管只有一个 goroutine 能够在main 函数前进到读取操作 (err = <-errs)。

为了解决您的问题，您可以创建一个额外的 goroutine，该 goroutine 会同时从通道读取数据，同时 goroutine 会写入通道。它看起来像这样：

func init() {
    rand.Seed(1500929006430687579)
}

func goroutine(n int, wg *sync.WaitGroup, ch chan error) {
    defer fmt.Println("defer done")
    defer wg.Done()

    fmt.Println("num ", n)
    if n == 1 {
        ch <- fmt.Errorf("error")
    }
}

func main() {
    var wg sync.WaitGroup
    errs := make(chan error)
    platforms := 2
    types := 3

    go func() {
        for e := range errs {
            fmt.Println(e)
        }
    }()

    for j := 0; j < platforms; j++ {
        for k := 0; k < types; k++ {
            wg.Add(1)
            n := rand.Intn(2)
            go goroutine(n, &wg, errs)
        }

        for k := 0; k < types; k++ {
            wg.Add(1)
            n := rand.Intn(2)
            go goroutine(n, &wg, errs)
        }
    }
    wg.Wait()
}

此外，我在您的代码中重构了一些错误和不准确之处：

1. 您不应该在有错误的通道中写入 nil。如果您希望 errs chan 仅包含错误，则仅当您的函数执行时出现非零错误时才在此处写入。
2. 您有一个额外的 wd.add(1) 作为 j 循环的开头，因此 add 函数和 done 函数之间存在不平衡。 3.
3. 此外，您可以在 defer wg.done() 之后添加 defer fmt.println("defer done")，但 defers 构造的执行顺序与指定顺序相反，因此将 defer fmt.println 放置起来会更正确（“延迟完成”） 在 defer wg.done() 之前，这样“延迟完成”实际上表明所有先前的 defer 都已被执行。

今天关于《从循环中收集嵌套的 goroutine 错误》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！