go - 使用 goroutine 和闭包从并发函数读取并发错误

Question

我有一个正在写入 channel 的函数(不是闭包)。我正在从 goroutine 中调用该函数作为

var wg sync.WaitGroup
wg.Add(1)
go DoStuff(somechan, &wg)

在 DoStuff 中，我有类似的东西

for ; ; {

    if err == io.EOF { 
        fmt.Println(err)
        close(somechan)
        fmt.Println("Closed channel")
        break
    } else if err != nil {
        panic(err)
    }
    somechan <- Somefunc()
}

现在我正在尝试使用另一个 goroutine 从该 channel 读取数据。

wgread.Add(1)
go func() {
    for ; ; {
        select {
        case chanoutput, ok := <-somechan:
            if ok == true {
                fmt.Println(string(*chanoutput))
            } else {
                fmt.Println("DONE")
                fmt.Println(ok)
                wgread.Done()
                break
            }
        }

    }
}()
wgread.Wait()

但是，在运行时，我得到了

panic: sync: negative WaitGroup counter

打印后

DONE
false
DONE
false

如果我给 wgread.Add(2)，它会打印上面的 DONE 和 false 3 次。

虽然我将 WaitGroup 增量递增 1，但为什么给出负 WaitGroup 计数器错误？使用另一个并发函数或闭包从 goroutine 读取数据的最佳方式是什么？

Answer 1

break 语句跳出最内层的 case，for 或 switch 语句。在 somechan 上接收的函数在一个循环中旋转，当 channel 关闭时递减 WaitGroup 。编写代码如下:

wgread.Add(1)
go func() {
    defer wgread.Done()
    for chanoutput := range somechan {
        fmt.Println(string(*chanoutput))
    }
    fmt.Println("DONE")
}()
wgread.Wait()

如果接收代码如题中所写，则接收goroutine可以消除。将 wgread.Add(1) 中的代码替换为 wgread.Wait() 为

for chanoutput := range somechan {
    fmt.Println(string(*chanoutput))
}