国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 編程 > Golang > 正文

Go語言WaitGroup使用時需要注意的坑

2020-04-01 19:07:52
字體:
來源:轉載
供稿:網友

前言

WaitGroup在go語言中,用于線程同步,單從字面意思理解,wait等待的意思,group組、團隊的意思,WaitGroup就是指等待一組,等待一個系列執行完成后才會繼續向下執行。Golang 中的 WaitGroup 一直是同步 goroutine 的推薦實踐。自己用了兩年多也沒遇到過什么問題。

直到最近的一天同事扔過來一段奇怪的代碼:

第一個坑

 

復制代碼 代碼如下:

package main
 
import (
    "log"
 
    "sync"
)
 
func main() {
    wg := sync.WaitGroup{}
 
    for i := 0; i < 5; i++ {
        go func(wg sync.WaitGroup, i int) {
            wg.Add(1)
            log.Printf("i:%d", i)
            wg.Done()
        }(wg, i)
    }
 
    wg.Wait()
 
    log.Println("exit")
}

 

撇了一眼,覺得沒什么問題。

然而,它的運行結果是這樣:

 

復制代碼 代碼如下:

2016/11/27 15:12:36 exit
[Finished in 0.7s]

 

或這樣:

 

復制代碼 代碼如下:

2016/11/27 15:21:51 i:2
2016/11/27 15:21:51 exit
[Finished in 0.8s]

 

或這樣:

 

復制代碼 代碼如下:

2016/11/27 15:22:51 i:3
2016/11/27 15:22:51 i:2
2016/11/27 15:22:51 exit
[Finished in 0.8s]

 

一度讓我以為手上的 mac 也沒睡醒……

這個問題如果理解了 WaitGroup 的設計目的就非常容易 fix 啦。因為 WaitGroup 同步的是 goroutine, 而上面的代碼卻在 goroutine 中進行 Add(1) 操作。因此,可能在這些 goroutine 還沒來得及 Add(1) 已經執行 Wait 操作了。

于是代碼改成了這樣:

第二個坑

 

復制代碼 代碼如下:

package main
 
import (
    "log"
 
    "sync"
)
 
func main() {
    wg := sync.WaitGroup{}
 
    for i := 0; i < 5; i++ {
        wg.Add(1)
        go func(wg sync.WaitGroup, i int) {
            log.Printf("i:%d", i)
            wg.Done()
        }(wg, i)
    }
 
    wg.Wait()
 
    log.Println("exit")
}

 

然而,mac 又睡了過去,而且是睡死了過去:

 

復制代碼 代碼如下:

2016/11/27 15:25:16 i:1
2016/11/27 15:25:16 i:2
2016/11/27 15:25:16 i:4
2016/11/27 15:25:16 i:0
2016/11/27 15:25:16 i:3
fatal error: all goroutines are asleep - deadlock!

 

wg 給拷貝傳遞到了 goroutine 中,導致只有 Add 操作,其實 Done操作是在 wg 的副本執行的。因此 Wait 就死鎖了。

于是代碼改成了這樣:

填坑

 

復制代碼 代碼如下:

package main
 
import (
    "log"
 
    "sync"
)
 
func main() {
    wg := &sync.WaitGroup{}
 
    for i := 0; i < 5; i++ {
        wg.Add(1)
        go func(wg *sync.WaitGroup, i int) {
            log.Printf("i:%d", i)
            wg.Done()
        }(wg, i)
    }
 
    wg.Wait()
 
    log.Println("exit")
}
 

 

總結

好了,到這里終于解決了,以上就是關于Go語言WaitGroup使用時需要注意的一些坑,希望本文中提到的這些問題對大家學習或者使用Go語言的時候能有所幫助,如果有疑問大家可以留言交流。

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 怀化市| 沙河市| 临武县| 科技| 马边| 阿拉善右旗| 娄底市| 泽库县| 运城市| 大理市| 界首市| 肥城市| 洞口县| 镇坪县| 房山区| 饶平县| 通江县| 夏津县| 海林市| 徐水县| 开鲁县| 大连市| 于田县| 福清市| 阿勒泰市| 大冶市| 美姑县| 台北市| 博湖县| 秦皇岛市| 河北区| 乌兰察布市| 志丹县| 南投市| 卫辉市| 昔阳县| 象州县| 库尔勒市| 河池市| 金昌市| 平武县|