什麼是WaitGroups?以下這篇文章就來帶大家了解go語言中WaitGroups,介紹一下使用WaitGroups的方法,希望對大家有幫助!
WaitGroups
是同步你的goroutines的一種有效方式。想像一下,你和你的家人一起開車旅行。你的父親在一個條形商場或快餐店停下來,買些食物和上廁所。你最好想等大家回來後再開車去地平線。 WaitGroups
幫助你做到這一點。
WaitGroups
是透過呼叫標準函式庫中的sync
套件來定義的。
var wg sync.WaitGroup
那麼,什麼是WaitGroup
呢? WaitGroup
是一個結構,它包含了程式需要等待多少個goroutine
的某些資訊。它是一個包含你需要等待的goroutines
數量的群組。
WaitGroups有三個最重要的方法: Add
, Done
和 Wait
。
讓我們來看看一段程式碼:
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...
WaitGroup wg
的實例。 wg
中加入1,因為我們要等待一個goroutine
完成。 goroutine
。在goroutine
內部,我們對wg.Done()
進行延遲調用,以確保我們遞減要等待的goroutine
的數量。如果我們不這樣做,那麼程式碼將永遠等待goroutine
完成,並將導致死鎖。 goroutine
呼叫之後,我們要確保阻斷程式碼,直到WaitGroup
為空。我們透過呼叫wg.Wait()
來做到這一點。 現在我們知道如何使用WaitGroups,一個自然而然的想法將我們引向這個問題:為什麼使用WaitGroups而不是通道?
根據我的經驗,有幾個原因。
WaitGroups
往往比較直覺。當你閱讀一段程式碼時,當你看到一個WaitGroup
時,你會立即知道程式碼在做什麼。方法的名稱很明確,而且直奔主題。然而,對於通道來說,有時就不是那麼清楚了。使用通道是很聰明的,但當你閱讀一段複雜的程式碼時,理解起來會很麻煩。 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...")
你可以看到,這個goroutine
並沒有與其他goroutine
進行資料交流。如果你的goroutine
是一次性的工作,你不需要知道結果,使用WaitGroup
是可取的。現在來看看這段程式碼:
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
發送資料。在這些情況下,我們不需要使用WaitGroup
,因為這將是多餘的。如果接收已經做了足夠的阻塞,為什麼還要等待goroutine
完成?
WaitGroups
是專門用來處理等待goroutines
的。我覺得通道的主要目的是為了交流數據。你不能用WaitGroup
來傳送和接收數據,但你可以用一個channel
來同步你的goroutines
。
最後,沒有正確的答案。我知道這可能很煩人,但這取決於你和你工作的團隊。無論什麼方法都是最好的,沒有答案是錯的。我個人傾向於使用WaitGroups
進行同步,但你的情況可能會有所不同。選擇對你來說最直觀的東西。
有時,你可能需要將WaitGroup
實例傳遞給goroutine
。可能有幾個WaitGroup
來處理不同的goroutine
,也可能是設計選擇。不管是什麼原因,請確保傳遞指向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是一種值傳遞的語言。這意味著每當你向一個函數傳遞一個參數時,Go會複製一個參數並傳遞給它而不是原始物件。在這種情況下發生的是,整個WaitGroup
物件將被複製,這意味著goroutine
將處理一個完全不同的WaitGroup。 wg.Done()
不會從原始的wg中減去,而是減去它的一個副本,這個副本只存在於goroutine
。
透過使用WaitGroups
,我們可以輕鬆同步goroutines
,從而確保我們的程式碼在正確的時間執行。儘管通道也可以用於同步,但WaitGroups
通常更直觀且更易於閱讀。使用WaitGroup
時,請確保正確傳遞指向WaitGroup
的指針,以防止副本問題出現。無論您選擇哪種方法,都應該選擇最直觀和最適合您和您的團隊的方法。
推薦學習:Golang教學
以上是go語言中什麼是WaitGroups?怎麼使用?的詳細內容。更多資訊請關注PHP中文網其他相關文章!