| | |
|---|
| | | 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()这里会发生阻塞，直到队列中所有的任务结束就会解除阻塞 |
|---|
| | |
|---|
| | | 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) |
|---|
