亚洲激情专区-91九色丨porny丨老师-久久久久久久女国产乱让韩-国产精品午夜小视频观看

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

Golang中的WaitGroups怎么使用

發布時間:2023-03-14 16:19:58 來源:億速云 閱讀:135 作者:iii 欄目:開發技術

本篇內容介紹了“Golang中的WaitGroups怎么使用”的有關知識,在實際案例的操作過程中,不少人都會遇到這樣的困境,接下來就讓小編帶領大家學習一下如何處理這些情況吧!希望大家仔細閱讀,能夠學有所成!

什么是WaitGroups

WaitGroups是同步你的goroutines的一種有效方式。想象一下,你和你的家人一起駕車旅行。你的父親在一個條形商場或快餐店停下來,買些食物和上廁所。你最好想等大家回來后再開車去地平線。WaitGroups幫助你做到這一點。

WaitGroups是通過調用標準庫中的sync包來定義的。

var wg sync.WaitGroup

那么,什么是WaitGroup呢?WaitGroup是一個結構,它包含了程序需要等待多少個goroutine的某些信息。它是一個包含你需要等待的goroutines數量的組。

WaitGroups有三個最重要的方法: AddDone和 Wait

  • Add: 添加到你需要等待的goroutines的總量上。

  • Done: 從你需要等待的goroutines總數中減去一個。

  • Wait: 阻止代碼繼續進行,直到沒有更多的goroutines需要等待。

如何使用WaitGroups

讓我們來看看一段代碼:

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而不是channel

現在我們知道了如何使用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中。

“Golang中的WaitGroups怎么使用”的內容就介紹到這里了,感謝大家的閱讀。如果想了解更多行業相關的知識可以關注億速云網站,小編將為大家輸出更多高質量的實用文章!

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

湖北省| 莱芜市| 忻州市| 勃利县| 松江区| 客服| 息烽县| 望城县| 南京市| 天水市| 平陆县| 南川市| 军事| 宜都市| 阿勒泰市| 南通市| 临颍县| 昌都县| 平山县| 乌拉特中旗| 廊坊市| 正镶白旗| 遂宁市| 特克斯县| 高平市| 文安县| 旬邑县| 思南县| 天峨县| 明光市| 通河县| 达日县| 永川市| 汾阳市| 安塞县| 吉安市| 娱乐| 西峡县| 梁河县| 东宁县| 什邡市|