這篇文章主要講解了“go語(yǔ)言中的WaitGroups如何使用”，文中的講解內(nèi)容簡(jiǎn)單清晰，易于學(xué)習(xí)與理解，下面請(qǐng)大家跟著小編的思路慢慢深入，一起來(lái)研究和學(xué)習(xí)“go語(yǔ)言中的WaitGroups如何使用”吧！
創(chuàng)新互聯(lián)建站是一家專(zhuān)注于網(wǎng)站設(shè)計(jì)制作、網(wǎng)站設(shè)計(jì)與策劃設(shè)計(jì),若羌網(wǎng)站建設(shè)哪家好?創(chuàng)新互聯(lián)建站做網(wǎng)站,專(zhuān)注于網(wǎng)站建設(shè)十載,網(wǎng)設(shè)計(jì)領(lǐng)域的專(zhuān)業(yè)建站公司;建站業(yè)務(wù)涵蓋:若羌等地區(qū)。若羌做網(wǎng)站價(jià)格咨詢(xún):18980820575
WaitGroups是同步你的goroutines的一種有效方式。想象一下，你和你的家人一起駕車(chē)旅行。你的父親在一個(gè)條形商場(chǎng)或快餐店停下來(lái)，買(mǎi)些食物和上廁所。你最好想等大家回來(lái)后再開(kāi)車(chē)去地平線(xiàn)。WaitGroups幫助你做到這一點(diǎn)。
WaitGroups是通過(guò)調(diào)用標(biāo)準(zhǔn)庫(kù)中的sync包來(lái)定義的。
var wg sync.WaitGroup
那么，什么是WaitGroup呢？WaitGroup是一個(gè)結(jié)構(gòu)，它包含了程序需要等待多少個(gè)goroutine的某些信息。它是一個(gè)包含你需要等待的goroutines數(shù)量的組。
WaitGroups有三個(gè)最重要的方法: Add, Done和 Wait。
Add: 添加到你需要等待的goroutines的總量上。
Done: 從你需要等待的goroutines總數(shù)中減去一個(gè)。
Wait: 阻止代碼繼續(xù)進(jìn)行，直到?jīng)]有更多的goroutines需要等待。
讓我們來(lái)看看一段代碼：
package main
import (
"fmt"
"sync"
"time"
)
func main() {
var wg sync.WaitGroup
wg.Add(1)
go func() {
defer wg.Done()
fmt.Println(time.Now(), "start")
time.Sleep(time.Second)
fmt.Println(time.Now(), "done")
}()
wg.Wait()
fmt.Println(time.Now(), "exiting...")
}2022-08-21 17:01:54.184744229 +0900 KST m=+0.000021800 start
2022-08-21 17:01:55.184932851 +0900 KST m=+1.000210473 done
2022-08-21 17:01:55.18507731 +0900 KST m=+1.000354912 exiting...
我們首先初始化一個(gè)WaitGroup wg的實(shí)例。
然后我們?cè)?code>wg中添加1，因?yàn)槲覀円却粋€(gè)goroutine完成。
然后我們運(yùn)行這個(gè)goroutine。在goroutine內(nèi)部，我們對(duì)wg.Done()進(jìn)行延遲調(diào)用，以確保我們遞減要等待的goroutine的數(shù)量。如果我們不這樣做，那么代碼將永遠(yuǎn)等待goroutine完成，并將導(dǎo)致死鎖。
在goroutine調(diào)用之后，我們要確保阻斷代碼，直到WaitGroup為空。我們通過(guò)調(diào)用wg.Wait()來(lái)做到這一點(diǎn)。
現(xiàn)在我們知道了如何使用WaitGroups，一個(gè)自然而然的想法將我們引向這個(gè)問(wèn)題：為什么使用WaitGroups而不是通道？
根據(jù)我的經(jīng)驗(yàn)，有幾個(gè)原因。
WaitGroups往往更直觀。當(dāng)你閱讀一段代碼時(shí)，當(dāng)你看到一個(gè)WaitGroup時(shí)，你會(huì)立即知道代碼在做什么。方法的名稱(chēng)很明確，而且直奔主題。然而，對(duì)于通道來(lái)說(shuō)，有時(shí)就不是那么清楚了。使用通道是很聰明的，但當(dāng)你閱讀一段復(fù)雜的代碼時(shí)，理解起來(lái)會(huì)很麻煩。
有的時(shí)候，你不需要使用通道。例如，讓我們看一下這段代碼：
var wg sync.WaitGroup
for i := 0; i < 5; i++ {
wg.Add(1)
go func() {
defer wg.Done()
fmt.Println(time.Now(), "start")
time.Sleep(time.Second)
fmt.Println(time.Now(), "done")
}()
}
wg.Wait()
fmt.Println(time.Now(), "exiting...")
你可以看到，這個(gè)goroutine并沒(méi)有與其他goroutine進(jìn)行數(shù)據(jù)交流。如果你的goroutine是一次性的工作，你不需要知道結(jié)果，使用WaitGroup是可取的?，F(xiàn)在看一下這段代碼：
ch := make(chan int)
for i := 0; i < 5; i++ {
go func() {
randomInt := rand.Intn(10)
ch <- randomInt
}()
}
for i := 0; i < 5; i++ {
fmt.Println(<-ch)
}
這里，goroutine正在向 channel 發(fā)送數(shù)據(jù)。在這些情況下，我們不需要使用WaitGroup，因?yàn)檫@將是多余的。如果接收已經(jīng)做了足夠的阻塞，為什么還要等待goroutine完成？
WaitGroups是專(zhuān)門(mén)用來(lái)處理等待goroutines的。我覺(jué)得通道的主要目的是為了交流數(shù)據(jù)。你不能用WaitGroup來(lái)發(fā)送和接收數(shù)據(jù)，但你可以用一個(gè)channel來(lái)同步你的goroutines。
最后，沒(méi)有正確的答案。我知道這可能很煩人，但這取決于你和你工作的團(tuán)隊(duì)。無(wú)論什么方法都是最好的，沒(méi)有答案是錯(cuò)誤的。我個(gè)人傾向于使用WaitGroups進(jìn)行同步，但你的情況可能有所不同。選擇對(duì)你來(lái)說(shuō)最直觀的東西。
有時(shí)，你可能需要將WaitGroup實(shí)例傳遞給goroutine?？赡苡袔讉€(gè)WaitGroup來(lái)處理不同的goroutine，也可能是一種設(shè)計(jì)選擇。不管是什么原因，請(qǐng)確保傳遞指向WaitGroup的指針，像這樣：
var wg sync.WaitGroup
for i := 0; i < 5; i++ {
wg.Add(1)
go func(wg *sync.WaitGroup) {
defer wg.Done()
fmt.Println(time.Now(), "start")
time.Sleep(time.Second)
fmt.Println(time.Now(), "done")
}(&wg)
}
wg.Wait()
fmt.Println(time.Now(), "exiting...")
原因是Go是一種值傳遞的語(yǔ)言。這意味著每當(dāng)你向一個(gè)函數(shù)傳遞一個(gè)參數(shù)時(shí)，Go會(huì)復(fù)制一個(gè)參數(shù)并傳遞給它而不是原始對(duì)象。在這種情況下發(fā)生的是，整個(gè)WaitGroup對(duì)象將被復(fù)制，這意味著goroutine將處理一個(gè)完全不同的WaitGroup。wg.Done()不會(huì)從原始的wg中減去，而是減去它的一個(gè)副本，這個(gè)副本只存在于goroutine中。
感謝各位的閱讀，以上就是“go語(yǔ)言中的WaitGroups如何使用”的內(nèi)容了，經(jīng)過(guò)本文的學(xué)習(xí)后，相信大家對(duì)go語(yǔ)言中的WaitGroups如何使用這一問(wèn)題有了更深刻的體會(huì)，具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是創(chuàng)新互聯(lián)，小編將為大家推送更多相關(guān)知識(shí)點(diǎn)的文章，歡迎關(guān)注！
重慶分公司
重慶分公司
