go wg test

sunty

2020-04-16 68ed73b2966171ef16a0b6623a9eb9c2d0968ea5

go wg  test

 controllers/swfsControllers.go

@@ -230,10 +230,11 @@
            for i := 0; i < len(masterIp); i++ {
                fmt.Println("len masterIp: ", len(masterIp))
                fmt.Println("第" + strconv.Itoa(i) + "个线程")
                go Restart(masterIp[i], timeOut)
                fmt.Println("当前goroutinebe")
                waitGroup.Add(1) //每创建一个goroutine，就把任务队列中任务的数量+1
                fmt.Println("当前goroutineaf")
                go Restart(masterIp[i], timeOut)
                waitGroup.Done()
            }
            fmt.Println("这里为阻塞！！！！！")
            waitGroup.Wait() //.Wait()这里会发生阻塞，直到队列中所有的任务结束就会解除阻塞
@@ -245,8 +246,9 @@
            if len(peersIp) == i+1 {
                var waitGroup sync.WaitGroup
                for i := 0; i < len(masterIp); i++ {
                    go Restart(masterIp[i], timeOut)
                    waitGroup.Add(1) //每创建一个goroutine，就把任务队列中任务的数量+1
                    go Restart(masterIp[i], timeOut)
                    waitGroup.Done()
                }
                waitGroup.Wait() //.Wait()这里会发生阻塞，直到队列中所有的任务结束就会解除阻塞
                masterIp = make([]string, 0)