Wait group

wait group 通常用来等待一组 goroutine 完成工作。
wait group 维护了一个 counter，并且依据 counter 的数字来控制 goroutine。透过三个操作来控制

• Add(delta int): 将 counter 加 delta。如果 counter 变为 0，被 Wait() 所挡住的 goroutine 将会放行。
• Done(): 将 conter 减 1，其实它的实作就是 Add(-1)。
• Wait(): 一直等待，直到 counter 变为 0。

以下给一个程序的例子，定义一个 worker，并且让五个 worker 做事，五个 worker 做完事情後，counter 一定为 0，这时正在 wait 的 main goroutine 才会继续执行。

func worker(id int) {
    fmt.Printf("Worker %d starting\n", id)
    time.Sleep(time.Second)
    fmt.Printf("Worker %d done\n", id)
}
func main() {
    var wg sync.WaitGroup
    for i := 1; i <= 5; i++ {
        wg.Add(1)
        i := i
        go func() {
            defer wg.Done()
            worker(i)
        }()
    }
    wg.Wait()
}

 在 go 里很常使用到错误处理，但是 wait group 本身并没有支援错误处理流程，自己设计错误处理又很容易犯错。errgroup package 就可以解决这个问题。而且 errgroup 同时支援 context 的做法，下一次就来写 errgroup 吧

Reference

• https://pkg.go.dev/sync#WaitGroup
• https://gobyexample.com/waitgroups
• https://go101.org/article/concurrent-synchronization-more.html#waitgroup