小编Sev*_*rin的帖子

我今天一直在玩 Goroutines、Channels 和 WaitGroup，在阅读了一段时间之后，我终于开始理解这个概念。

我的问题是我不确定在这样工作时如何处理错误，主要是因为我使用了 WaitGroup。使用 WaitGroup 时，我首先添加将要执行的 goroutine 的数量，但是如果在其中一个过程中发生错误怎么办？

package main

import (
    "errors"
    "sync"
)

var waitGroup sync.WaitGroup

func main() {
    c := make(chan int, 10)

    waitGroup.Add(10)

    go doSomething(c)

    waitGroup.Wait()
}

func doSomething(c chan int) {
    for i := 0; i < 10; i++ {
        n, err := someFunctionThatCanError()

        if err != nil {
            // How do I end the routines and WaitGroups here?
        }

        c <- n
        waitGroup.Done()
    }

    close(c)    
}

func someFunctionThatCanError() (int, error) {
    return …