日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢(xún)
選擇下列產(chǎn)品馬上在線(xiàn)溝通
服務(wù)時(shí)間:8:30-17:00
你可能遇到了下面的問(wèn)題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷(xiāo)解決方案
Golang中的同步工具Sync.WaitGroup詳解

sync.WaitGroup

sync.WaitGroup作用是等待一組goroutine執(zhí)行完成,當(dāng)使用多個(gè)goroutine處理任務(wù)的時(shí)候,如果要等待所有的goroutine都執(zhí)行完成后再執(zhí)行下一步操作,就可以使用sync.WaitGroup來(lái)實(shí)現(xiàn)。

鐵門(mén)關(guān)ssl適用于網(wǎng)站、小程序/APP、API接口等需要進(jìn)行數(shù)據(jù)傳輸應(yīng)用場(chǎng)景,ssl證書(shū)未來(lái)市場(chǎng)廣闊!成為創(chuàng)新互聯(lián)的ssl證書(shū)銷(xiāo)售渠道,可以享受市場(chǎng)價(jià)格4-6折優(yōu)惠!如果有意向歡迎電話(huà)聯(lián)系或者加微信:18982081108(備注:SSL證書(shū)合作)期待與您的合作!

sync.WaitGroup有三個(gè)方法:

  1. Add(delta int):增加或減少等待goroutine的數(shù)量,delta可以為負(fù)數(shù);
  2. Done():標(biāo)記goroutine已執(zhí)行完成,等價(jià)于Add(-1);
  3. Wait():等待所有的goroutine執(zhí)行完成。

使用方法和示例

假如有n個(gè)任務(wù)需要處理,可以先創(chuàng)建一個(gè)WaitGroup,用于等待所有的任務(wù)完成:

var wg sync.WaitGroup

在處理每一個(gè)任務(wù)之前,調(diào)用一次Add方法:

wg.Add(1)

在每一個(gè)任務(wù)處理完成之后,調(diào)用一次Done方法:

wg.Done()

最后,在等待所有的任務(wù)完成之前,需要調(diào)用一次Wait方法:

wg.Wait()

具體示例代碼如下:

package main

import (
	"log"
	"sync"
	"time"
)

func main() {
	// 創(chuàng)建一個(gè)等待組
	var wg sync.WaitGroup

	for i := 1; i <= 5; i++ {
		// 每一個(gè)任務(wù)開(kāi)始前, 增加1
		wg.Add(1)

		go func(index int) {
			// 處理業(yè)務(wù)邏輯
			//...
			time.Sleep(1 * time.Second)
			log.Printf("第 %d 個(gè)goroutine執(zhí)行完了", index)
			wg.Done()
		}(i)
	}
	// 等待所有的任務(wù)完成
	wg.Wait()
	log.Println("所有g(shù)oroutine都執(zhí)行完了")
}

使用過(guò)程中需要注意的點(diǎn)

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

分享題目:Golang中的同步工具Sync.WaitGroup詳解
瀏覽地址:http://www.5511xx.com/article/djddjgs.html