首頁  >  文章  >  後端開發  >  為了在 Go 中正確同步 Goroutine,應該將 `wg.Add()` 和 `wg.Done()` 放在哪裡?

為了在 Go 中正確同步 Goroutine,應該將 `wg.Add()` 和 `wg.Done()` 放在哪裡?

Susan Sarandon
Susan Sarandon原創
2024-11-04 05:28:29793瀏覽

 Where Should You Place `wg.Add()` and `wg.Done()` for Correct Goroutine Synchronization in Go?

用於Goroutine 同步的WaitGroup 插入位置

在Go 中,sync.WaitGroup 類型透過追蹤活動的數量來促進Goroutine的同步goroutine 並等待所有goroutine 完成執行後再繼續。正確放置 wg.Add() 和 wg.Done() 呼叫對於確保正確的行為至關重要。

考慮以下程式碼:

<code class="go">var wg sync.WaitGroup
var v int32 = 0 
for i = 0; i < 100; i++{
   go func(){
       wg.Add(1) // wrong place
       atomic.AddInt32(&v,1)
       wg.Done()
   } 
}
wg.Wait()
fmt.Println(v)</code>

在此範例中,wg.Add( 1) 被錯誤地放置在匿名函數中。這種不正確的放置可能會導致 v 值不一致,通常小於 100。

這種差異的原因在於 goroutine 的並發性質。當放置在 goroutine 中時,wg.Add(1) 可能會與 wg.Done() 同時運行,導致 wg.Wait() 過早恢復並低估已完成的 goroutine 數量。

要解決此問題,在啟動每個goroutine 之前,應將wg.Add(1) 放置在for 循環中:

<code class="go">var wg sync.WaitGroup
var v int32 = 0 
for i = 0; i < 100; i++{
   wg.Add(1)
   go func(){
       atomic.AddInt32(&v,1)
       wg.Done()
   } 
}
wg.Wait()
fmt.Println(v)</code>

此調整可確保wg.Wait()將阻塞,直到所有wg.Done() 呼叫完成,允許v 準確反映已完成的goroutine 數量。

總之,始終在啟動 goroutine 之前放置 wg.Add() ,並在 goroutine 完成執行後放置 wg.Done() 以確保正確的同步和可靠的結果計算。

以上是為了在 Go 中正確同步 Goroutine,應該將 `wg.Add()` 和 `wg.Done()` 放在哪裡?的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述:
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn