新聞中心
這里有您想知道的互聯網營銷解決方案
Golang中的同步工具Sync.WaitGroup詳解
sync.WaitGroup
sync.WaitGroup作用是等待一組goroutine執(zhí)行完成,當使用多個goroutine處理任務的時候,如果要等待所有的goroutine都執(zhí)行完成后再執(zhí)行下一步操作,就可以使用sync.WaitGroup來實現。

鐵門關ssl適用于網站、小程序/APP、API接口等需要進行數據傳輸應用場景,ssl證書未來市場廣闊!成為創(chuàng)新互聯的ssl證書銷售渠道,可以享受市場價格4-6折優(yōu)惠!如果有意向歡迎電話聯系或者加微信:18982081108(備注:SSL證書合作)期待與您的合作!
sync.WaitGroup有三個方法:
- Add(delta int):增加或減少等待goroutine的數量,delta可以為負數;
- Done():標記goroutine已執(zhí)行完成,等價于Add(-1);
- Wait():等待所有的goroutine執(zhí)行完成。
使用方法和示例
假如有n個任務需要處理,可以先創(chuàng)建一個WaitGroup,用于等待所有的任務完成:
var wg sync.WaitGroup在處理每一個任務之前,調用一次Add方法:
wg.Add(1)在每一個任務處理完成之后,調用一次Done方法:
wg.Done()最后,在等待所有的任務完成之前,需要調用一次Wait方法:
wg.Wait()具體示例代碼如下:
package main
import (
"log"
"sync"
"time"
)
func main() {
// 創(chuàng)建一個等待組
var wg sync.WaitGroup
for i := 1; i <= 5; i++ {
// 每一個任務開始前, 增加1
wg.Add(1)
go func(index int) {
// 處理業(yè)務邏輯
//...
time.Sleep(1 * time.Second)
log.Printf("第 %d 個goroutine執(zhí)行完了", index)
wg.Done()
}(i)
}
// 等待所有的任務完成
wg.Wait()
log.Println("所有goroutine都執(zhí)行完了")
}
使用過程中需要注意的點
- Done和Add方法的順序非常重要,Done方法必須在goroutine最后執(zhí)行,否則可能會導致計數器無法正確的達到0;
- 如果使用Add或Done方法將wg維護的計數更改成了負數會導致panic;
- Wait方法會一直阻塞,直到所有的goroutine都執(zhí)行完成為止(wg維護的計數達到0),因此在使用時需要小心;
- sync.WaitGroup是開箱即用的,并且是并發(fā)安全的。
網頁題目:Golang中的同步工具Sync.WaitGroup詳解
瀏覽地址:http://www.dlmjj.cn/article/djddjgs.html


咨詢
建站咨詢
