首頁  >  文章  >  後端開發  >  為什麼我的 Gosync.WaitGroup 沒有完成?

為什麼我的 Gosync.WaitGroup 沒有完成?

Barbara Streisand
Barbara Streisand原創
2024-11-27 04:57:14284瀏覽

Why Doesn't My Go sync.WaitGroup Ever Complete?

Golangsync.WaitGroup Never Completes

提供的程式碼透過取得URL 清單並有條件地下載和儲存檔案到檔案到檔案系統。主 goroutine 等待使用sync.WaitGroup 取得所有檔案。但是,即使完成所有請求,程式也無法退出。

要理解此問題,請考慮 WaitGroup 的功能。它維護正在執行的 goroutine 的計數。如果計數達到零,waitgroup 立即返回,表示所有 goroutine 已完成執行。

在給定的程式碼中,WaitGroup 的 Add 方法用於增加計數,而 Done 方法用於減少計數。如果 Add 方法被呼叫的次數多於 Done 方法,反之亦然,WaitGroup 將永遠不會達到零,導致主 goroutine 無限期等待。

提供的程式碼中有兩個錯誤:

  1. downloadFromURL 函數接收 WaitGroup 的副本,而不是指向它的指標。這會導致 WaitGroup 內部資料的副本被傳遞,因此函數內對其進行的任何修改(例如呼叫 Done)對於主 goroutine 都是不可見的。要解決此問題,請將指標傳遞給 WaitGroup:
func main() {
    ...
    go downloadFromURL(url, &wg)
    ...
}
  1. defer wg.Done() 語句不會作為 downloadFromURL 函數中的第一個語句放置。如果在呼叫 Done 之前發生錯誤或執行任何其他邏輯,則遞減操作將不會被註冊,且 WaitGroup 的計數永遠不會達到零。要解決此問題,請確保defer wg.Done() 是函數中的第一個語句:
func downloadFromURL(url string, wg *sync.WaitGroup) error {
    defer wg.Done()
    ...
}

完成這些修正後,WaitGroup 將正確運行,隨著goroutine 完成其計數而減少其計數任務,最終導致主協程成功退出。

以上是為什麼我的 Gosync.WaitGroup 沒有完成?的詳細內容。更多資訊請關注PHP中文網其他相關文章!

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