关于golang:Go-sync包的WaitGroup同步等待组详解

    sync全称是synchronization，意思是同步。
WaitGroup同步期待组是有一组goroutine要期待执行，而以后的goroutine须要期待这一组goroutine都执行完能力执行。
    上面是WaitGroup的定义：

type WaitGroup struct {
    //
}

    每个WaitGroup中都有一个计数器counter记录要期待执行gorouting的数量，能够通过Add这个办法来设置同步期待组中期待goroutine的个数。每个goroutine都会执行，执行完之后都会调用done办法示意把计数器的值-1，与此同时，应用wait办法阻塞，直到所goroutine都执行结束。
func (wg *WaitGroup) Add(delta int)

• 如果计数器的值为0，那么期待过程中被阻塞的goroutine都会被开释
• 如果计数器得悉为负，那么就会引发panic

那么具体什么状况下用，怎么应用呢？
上面举个例子：

package main

import "fmt"

func main() {
    //waitGroup
    go fun1()
    go fun2()
}

func fun1() {
    for i := 1; i < 10; i++ {
        fmt.Println("print A in fun1", i)
    }
}

func fun2() {
    for i := 0; i < 10; i++ {
        fmt.Println("\t fun2 print: ", i)
    }
}

这样最初什么都没有打印，因为主goroutine在fun1 fun2这两个goroutine执行之前完结了。这时候就能够用WaitGroup了。

package main

import (
    "fmt"
    "sync"
)

//创立同步期待组
var wg sync.WaitGroup

func main() {
    //waitGroup
    wg.Add(2) //设置计数器为2（goroutine的个数）
    go fun1()
    go fun2()
    fmt.Println("main 进入阻塞状态， 须要期待wg的goroutine完结")
    wg.Wait() //示意main goroutine进入阻塞
    fmt.Println("计数器归零 进行阻塞")
}

func fun1() {
    defer wg.Done() //计数器-1
    for i := 1; i < 10; i++ {
        fmt.Println("print A in fun1", i)
    }
}

func fun2() {
    defer wg.Done() //计数器-1
    for i := 0; i < 10; i++ {
        fmt.Println("\t fun2 print: ", i)
    }
}

后果如下：

main 进入阻塞状态， 须要期待wg的goroutine完结
print A in fun1 1
print A in fun1 2
         fun2 print:  0
         fun2 print:  1
         fun2 print:  2
         fun2 print:  3
         fun2 print:  4
print A in fun1 3
print A in fun1 4
print A in fun1 5
print A in fun1 6
print A in fun1 7
print A in fun1 8
print A in fun1 9
         fun2 print:  5
         fun2 print:  6
         fun2 print:  7
         fun2 print:  8
         fun2 print:  9
计数器归零 进行阻塞

后果第一行，阐明两个goroutine曾经都启动了，而后交替应用CPU的工夫片。
另外 如果函数执行结束的时候，计数器的值依然大于0，会引起deadlock。

另外 Go语言并不举荐上述写法，更加举荐应用chanel。

材料参考：bilibili