登录
首页 >  Golang >  Go问答

自同步 Goroutine 以死锁告终

来源:stackoverflow

时间:2024-04-10 16:54:37 426浏览 收藏

各位小伙伴们,大家好呀!看看今天我又给各位带来了什么文章?本文标题《自同步 Goroutine 以死锁告终》,很明显是关于Golang的文章哈哈哈,其中内容主要会涉及到等等,如果能帮到你,觉得很不错的话,欢迎各位多多点评和分享!

问题内容

我有一个压力测试问题,想通过 go 中的简单同步来解决。到目前为止,我已经尝试查找有关 go 中同步的特定用例的文档,但没有找到任何合适的内容。

更具体一点: 我必须完成一项任务,必须在主例程中启动大量线程(在本示例中仅用两个线程进行说明)。所有启动的工作人员都应该以无序的方式自行准备一些初始化操作。直到它们到达一小段命令,我希望它们立即由所有 goroutine 执行,这就是为什么我想使 goroutine 彼此自同步。对于我的任务来说,非常重要的是,通过实例化所有其他 goroutine 的主例程的延迟不会影响工作线程执行的真正并行性(在注释中的标签 #maximumparallel 处)。为此,我使用主例程中正在运行的 goroutine 数量初始化一个等待组,并将其传递给所有例程,以便它们可以同步彼此的工作流程。

代码看起来与此示例类似:

import sync

func worker_action(wait_group *sync.WaitGroup) {
    // ...
    // initialization
    // ...

    defer wait_group.Done() 
    wait_group.Wait() // #label: wait

    // sequence of maximum parallel instructions // #label: maximum parallel

    // ...
}

func main() {
    var numThreads int = 2 // the number of threads shall be much higher for the actual stress test

    var wait_group sync.WaitGroup
    wait_group.Add(numThreads)
    for i := 0; i < numThreads; i++ {
        go worker_action(&wait_group)
    }

    // ...
}

不幸的是,一旦所有 goroutine 到达等待指令(在注释中标有 #wait),我的设置就会陷入僵局。对于我从主例程开始的任何数量的线程都是如此(甚至两个线程很快就会陷入死锁)。

从我的角度来看,死锁不应该发生,因为在等待指令之前,每个 goroutine 都会在同一个等待组上执行 did 函数。

我对等待组的工作方式是否有错误的理解?例如,是否不允许在除主例程之外的 goroutine 中执行等待函数?或者有人可以提示我还缺少什么吗?

提前非常感谢您。

编辑:

非常感谢@tkausl。确实是不必要的“推迟”造成了问题。我不知道我自己怎么看不到它。


解决方案


您的代码中有几个问题。首先是形式。惯用的 go 应该使用驼峰命名法。 wg 是 waitgroup 的更好名称。

但更重要的是代码等待的地方的使用。不在你的 goroutines 中。它应该在主函数内等待:

func workerAction(wg *sync.WaitGroup) {
    // ...
    // initialization
    // ...

    defer wg.Done() 
    // wg.Wait() // #label: wait

    // sequence of maximum parallel instructions // #label: maximum parallel

    // ...
}

func main() {
    var numThreads int = 2 // the number of threads shall be much higher for the actual stress test

    var wg sync.WaitGroup
    wg.Add(numThreads)
    for i := 0; i < numThreads; i++ {
        go workerAction(&wg)
    }
    wg.Wait() // you need to wait here

    // ...
}

理论要掌握,实操不能落!以上关于《自同步 Goroutine 以死锁告终》的详细介绍,大家都掌握了吧!如果想要继续提升自己的能力,那么就来关注golang学习网公众号吧!

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>