日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

RELATEED CONSULTING
相關咨詢
選擇下列產品馬上在線溝通
服務時間:8:30-17:00
你可能遇到了下面的問題
關閉右側工具欄

新聞中心

這里有您想知道的互聯網營銷解決方案
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有三個方法:

  1. Add(delta int):增加或減少等待goroutine的數量,delta可以為負數;
  2. Done():標記goroutine已執(zhí)行完成,等價于Add(-1);
  3. 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í)行完了")
}

使用過程中需要注意的點

  1. Done和Add方法的順序非常重要,Done方法必須在goroutine最后執(zhí)行,否則可能會導致計數器無法正確的達到0;
  2. 如果使用Add或Done方法將wg維護的計數更改成了負數會導致panic;
  3. Wait方法會一直阻塞,直到所有的goroutine都執(zhí)行完成為止(wg維護的計數達到0),因此在使用時需要小心;
  4. sync.WaitGroup是開箱即用的,并且是并發(fā)安全的。

網頁題目:Golang中的同步工具Sync.WaitGroup詳解
瀏覽地址:http://www.dlmjj.cn/article/djddjgs.html