自同步 Goroutine 以死锁告终

各位小伙伴们，大家好呀！看看今天我又给各位带来了什么文章？本文标题是《自同步 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学习网公众号吧！