欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Go sync WaitGroup使用深入理解

 更新時(shí)間:2022年10月25日 14:23:06   作者:亞洲第一中鋒_哈  
這篇文章主要為大家介紹了Go sync WaitGroup使用深入理解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪

基本介紹

WaitGroup是go用來做任務(wù)編排的一個(gè)并發(fā)原語(yǔ),它要解決的就是并發(fā) - 等待的問題:

當(dāng)有一個(gè) goroutine A 在檢查點(diǎn)(checkpoint)等待一組 goroutine 全部完成,如果這些 goroutine 還沒全部完成,goroutine A 就會(huì)阻塞在檢查點(diǎn),直到所有 goroutine 都完成后才能繼續(xù)執(zhí)行

試想如果沒有WaitGroup,想要在協(xié)程A等到其他協(xié)程執(zhí)行完成后能立馬執(zhí)行,只能不斷輪詢其他協(xié)程是否執(zhí)行完畢,這樣的問題是:

  • 及時(shí)性差:輪詢間隔越高,及時(shí)性越差
  • 無謂的空輪訓(xùn),浪費(fèi)系統(tǒng)資源

而用WaitGroup時(shí),協(xié)程A只用阻塞,直到其他協(xié)程執(zhí)行完畢后,再通知協(xié)程A

其他語(yǔ)言也提供了類似的工具,例如Java的CountDownLatch

使用

Waitgroup提供了3個(gè)方法:

func (wg *WaitGroup) Add(delta int)
func (wg *WaitGroup) Done()
func (wg *WaitGroup) Wait()

Add:增加計(jì)數(shù)值

Done:減少計(jì)數(shù)值

Wait:調(diào)用這個(gè)方法的 goroutine 會(huì)一直阻塞,直到 WaitGroup 的計(jì)數(shù)值變?yōu)?0

源碼分析

type WaitGroup struct {
   // 避免復(fù)制
   noCopy noCopy
   // 64位環(huán)境下,高32位是計(jì)數(shù)值,低32位記錄waiter的數(shù)量
   state1 uint64
   // 用于信號(hào)量
   state2 uint32
}

Add

func (wg *WaitGroup) Add(delta int) {
   // 獲取狀態(tài)值,信號(hào)量
   statep, semap := wg.state()
   // 將參數(shù)delta左32位,加到statep中,即給計(jì)數(shù)值加上delta
   state := atomic.AddUint64(statep, uint64(delta)<<32)
   // 加后的計(jì)數(shù)值
   v := int32(state >> 32)
   // waiter的數(shù)量
   w := uint32(state)
   // 加后不能是負(fù)值
   if v < 0 {
      panic( "sync: negative WaitGroup counter" )
   }
   // 有waiter的情況下,當(dāng)前協(xié)程又加了計(jì)數(shù)值,panic
   // 即有waiter的情況下,不能再給waitgroup增加計(jì)數(shù)值了
   if w != 0 && delta > 0 && v == int32(delta) {
      panic( "sync: WaitGroup misuse: Add called concurrently with Wait" )
   }
   // 如果加完后v大于0,或者加完后v等于0,但沒有等待者,直接返回
   if v > 0 || w == 0 {
      return
   }
   // 接下來就是v等于0,且w大于0的情況
   // 再次檢查是否有Add和Wait并發(fā)調(diào)用的情況
   if *statep != state {
      panic( "sync: WaitGroup misuse: Add called concurrently with Wait" )
   }
   // 將計(jì)數(shù)值和waiter數(shù)量清0
   *statep = 0
   // 喚醒所有的waiter
   for ; w != 0; w-- {
      runtime_Semrelease(semap, false, 0)
   }
}
  • 因?yàn)閟tate高32位保存計(jì)數(shù)值,因此需要將參數(shù)delta左移32位后加到state上才正確

如果加完后v大于0,或者加完后v等于0,但沒有等待者,直接返回

  • v大于0:表示自己不是最后一個(gè)調(diào)用Done的協(xié)程,不用自己來釋放waiter,直接返回
  • v等于0,但沒有等待者:因?yàn)闆]有等待者,也就不用釋放等待者,也直接返回

否則就是v等于0,且w大于0的情況:

自己是最后一個(gè)調(diào)用Done的,且還有等待者,那就喚醒所有等待者

Done

Done內(nèi)部調(diào)用Add,只是參數(shù)傳-1,表示減少計(jì)數(shù)值

func (wg *WaitGroup) Done() {
   wg.Add(-1)
}

Wait

func (wg *WaitGroup) Wait() {
   statep, semap := wg.state()
   for {
      state := atomic.LoadUint64(statep)
      // v:計(jì)數(shù)值
      v := int32(state >> 32)
      w := uint32(state)
      // 如果計(jì)數(shù)值為0,自己不需要等到,直接返回
      if v == 0 {
         return
   }
      // 增加waiter計(jì)數(shù)值
 if atomic.CompareAndSwapUint64(statep, state, state+1) {
         // 自己在信號(hào)量上阻塞
         runtime_Semacquire(semap)
         // 檢查Waitgroup是否在wait返回前被重用
         if *statep != 0 {
            panic( "sync: WaitGroup is reused before previous Wait has returned" )
         }
         return
      }
   }
}

如果計(jì)數(shù)值為0,當(dāng)前不需要阻塞,直接返回

否則將waiter數(shù)量加1,如果添加成功,就把自己阻塞到信號(hào)量上

被喚醒時(shí),如果statep不為0,表示該waitgroup是否在wait返回前被重用了,panic

注意事項(xiàng)

通過源碼分析可以看出,Waitgroup有以下使用注意事項(xiàng):

計(jì)數(shù)器的值必須大于等于0

一開始調(diào)用Add時(shí),不能傳負(fù)數(shù)

調(diào)用Done的次數(shù)不能過多,導(dǎo)致超過了 WaitGroup 的計(jì)數(shù)值

因此使用 WaitGroup 的正確姿勢(shì)是,預(yù)先確定好 WaitGroup 的計(jì)數(shù)值,然后調(diào)用相同次數(shù)的 Done 完成相應(yīng)的任務(wù)

保證在期望的Add調(diào)用完成后,再調(diào)用Wait,否則Wait發(fā)現(xiàn)計(jì)數(shù)值為0時(shí)不會(huì)阻塞

最好在一個(gè)協(xié)程中,按順序先調(diào)Add,再調(diào)Wait

需要重用時(shí),需要在前一組調(diào)用Wait結(jié)束后,再開始新一輪的使用

WaitGroup 是可以重用的。只要 WaitGroup 的計(jì)值恢復(fù)到零值的狀態(tài),那么它就可以被看作是新創(chuàng)建的 WaitGroup,被重復(fù)使用,而不能在前一組沒使用完的情況下又使用

以上就是Go sync WaitGroup使用深入理解的詳細(xì)內(nèi)容,更多關(guān)于Go sync WaitGroup使用的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章!

相關(guān)文章

  • golang中的struct操作

    golang中的struct操作

    結(jié)構(gòu)體是一種聚合的數(shù)據(jù)類型,是由零個(gè)或多個(gè)任意類型的值聚合成的實(shí)體,每個(gè)值稱為結(jié)構(gòu)體的成員。下面介紹下golang中的struct,感興趣的朋友一起看看吧
    2021-11-11
  • 如何解析golang中Context在HTTP服務(wù)中的角色

    如何解析golang中Context在HTTP服務(wù)中的角色

    這篇文章主要介紹了如何解析golang中Context在HTTP服務(wù)中的角色問題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2024-03-03
  • golang beyla采集trace程序原理源碼解析

    golang beyla采集trace程序原理源碼解析

    beyla支持通過ebpf,無侵入的、自動(dòng)采集應(yīng)用程序的trace信息,本文以golang的nethttp為例,講述beyla對(duì)trace的采集的實(shí)現(xiàn)原理,有需要的朋友可以借鑒參考下,希望能夠有所幫助
    2024-02-02
  • Go語(yǔ)言中new()和 make()的區(qū)別詳解

    Go語(yǔ)言中new()和 make()的區(qū)別詳解

    這篇文章主要介紹了Go語(yǔ)言中new()和 make()的區(qū)別詳解,本文講解了new 的主要特性、make 的主要特性,并對(duì)它們的區(qū)別做了總結(jié),需要的朋友可以參考下
    2014-10-10
  • 破解IDEA(Goland)注冊(cè)碼設(shè)置 license server一直有效不過期的過程詳解

    破解IDEA(Goland)注冊(cè)碼設(shè)置 license server一直有效不過期的過程詳解

    這篇文章主要介紹了破解IDEA(Goland)注冊(cè)碼設(shè)置 license server一直有效不過期,本文通過圖文并茂的形式給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2020-11-11
  • golang開發(fā)及數(shù)字證書研究分享

    golang開發(fā)及數(shù)字證書研究分享

    這篇文章主要為大家介紹了golang開發(fā)以及數(shù)字證書的研究示例分享,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步
    2021-11-11
  • Go設(shè)計(jì)模式之享元模式講解和代碼示例

    Go設(shè)計(jì)模式之享元模式講解和代碼示例

    享元是一種結(jié)構(gòu)型設(shè)計(jì)模式,它允許你在消耗少量?jī)?nèi)存的情況下支持大量對(duì)象,模式通過共享多個(gè)對(duì)象的部分狀態(tài)來實(shí)現(xiàn)上述功能,換句話來說,享元會(huì)將不同對(duì)象的相同數(shù)據(jù)進(jìn)行緩存以節(jié)省內(nèi)存,本文就將通過代碼示例給大家詳細(xì)介紹一下享元模式
    2023-06-06
  • go中make用法及常見的一些坑

    go中make用法及常見的一些坑

    golang分配內(nèi)存主要有內(nèi)置函數(shù)new和make,下面這篇文章主要給大家介紹了關(guān)于go中make用法及常見的一些坑,文中通過示例代碼介紹的非常詳細(xì),需要的朋友可以參考下
    2022-12-12
  • Go語(yǔ)言中sync.Mutex的使用方法

    Go語(yǔ)言中sync.Mutex的使用方法

    本文主要介紹了golang中sync.Mutex的實(shí)現(xiàn)方法,mutex主要有兩個(gè) method:Lock()和Unlock(),文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2023-03-03
  • 使用Go語(yǔ)言進(jìn)行條件編譯的示例代碼

    使用Go語(yǔ)言進(jìn)行條件編譯的示例代碼

    Go的條件編譯主要通過構(gòu)建標(biāo)簽(build?tags)和構(gòu)建約束(build?constraints)來實(shí)現(xiàn),這些標(biāo)簽和約束可以讓我們針對(duì)不同的操作系統(tǒng)、架構(gòu)或特定條件編寫特定代碼,本文給大家介紹了如何使用Go語(yǔ)言進(jìn)行條件編譯,需要的朋友可以參考下
    2024-06-06

最新評(píng)論