• 技术文章 >后端开发 >Golang

    分析Golang的WaitGroup陷阱并解决问题

    藏色散人藏色散人2021-09-14 15:57:02转载80
    本文由go语言教程栏目给大家介绍关于Golang的WaitGroup陷阱,希望对需要的朋友有所帮助!

    sync.WaitGroup是并发环境中,一个相当常用的数据结构,用来等待所有协程的结束,在写代码的时候都是按着例子的样子写的,也没用深究过它的使用。前几日想着能不能在协程中执行Add()函数,答案是不能,这里介绍下。

    陷阱在WaitGroup的3个函数的调用顺序上。先回顾下3个函数的功能:

    1. Add(delta int):给计数器增加delta,比如启动1个协程就增加1。
    2. Done():协程退出前执行,把计数器减1。
    3. Wait():阻塞等待计数器为0。

    考一考

    下面的程序是创建了协程father,然后father协程创建了10个子协程,main函数等待所有协程结束后退出,看看下面代码有没有什么问题?

    package main
    
    import (
        "fmt"
        "sync"
    )
    
    func father(wg *sync.WaitGroup) {
        wg.Add(1)
        defer wg.Done()
    
        fmt.Printf("father\n")
        for i := 0; i < 10; i++ {
            go child(wg, i)
        }
    }
    
    func child(wg *sync.WaitGroup, id int) {
        wg.Add(1)
        defer wg.Done()
    
        fmt.Printf("child [%d]\n", id)
    }
    
    func main() {
        var wg sync.WaitGroup
        go father(&wg)
    
        wg.Wait()
        log.Printf("main: father and all chindren exit")
    }

    发现问题了吗?如果没有看下面的运行结果:main函数在子协程结束前就开始结束了。

    father
    main: father and all chindren exit
    child [9]
    child [0]
    child [4]
    child [7]
    child [8]

    陷阱分析

    产生以上问题的原因在于,创建协程后在协程内才执行Add()函数,而此时Wait()函数可能已经在执行,甚至Wait()函数在所有Add()执行前就执行了,Wait()执行时立马就满足了WaitGroup的计数器为0,Wait结束,主程序退出,导致所有子协程还没完全退出,main函数就结束了。

    正确的做法

    Add函数一定要在Wait函数执行前执行,这在Add函数的文档中就提示了: Note that calls with a positive delta that occur when the counter is zero must happen before a Wait.

    如何确保Add函数一定在Wait函数前执行呢?在协程情况下,我们不能预知协程中代码执行的时间是否早于Wait函数的执行时间,但是,我们可以在分配协程前就执行Add函数,然后再执行Wait函数,以此确保。

    下面是修改后的程序,以及输出结果。

    package main
    
    import (
        "fmt"
        "sync"
    )
    
    func father(wg *sync.WaitGroup) {
        defer wg.Done()
    
        fmt.Printf("father\n")
        for i := 0; i < 10; i++ {
            wg.Add(1)
            go child(wg, i)
        }
    }
    
    func child(wg *sync.WaitGroup, id int) {
        defer wg.Done()
        fmt.Printf("child [%d]\n", id)
    }
    
    func main() {
        var wg sync.WaitGroup
        wg.Add(1)
        go father(&wg)
    
        wg.Wait()
        fmt.Println("main: father and all chindren exit")
    }
    father
    child [9]
    child [7]
    child [8]
    child [1]
    child [4]
    child [5]
    child [2]
    child [6]
    child [0]
    child [3]
    main: father and all chindren exit

    以上就是分析Golang的WaitGroup陷阱并解决问题的详细内容,更多请关注php中文网其它相关文章!

    声明:本文转载于:segmentfault,如有侵犯,请联系admin@php.cn删除
    专题推荐:golang wait goroutine
    上一篇:带你研究一下go zap的SugaredLogger! 下一篇:聊聊Golang进程守护Supervisor
    线上培训班

    相关文章推荐

    • 解析Golang怎么创建守护进程和平滑重启• 你或许听过对Golang map做GC?• 分享golang和vue3开发的一个im应用• 一文详解golang defer的实现原理• 字节对齐在golang中的使用详解

    全部评论我要评论

  • 取消发布评论发送
  • 1/1

    PHP中文网