解答带有 cond 和 waitgroup 的 goroutine 运行时的疑问

偷偷努力，悄无声息地变强，然后惊艳所有人！哈哈，小伙伴们又来学习啦~今天我将给大家介绍《解答带有 cond 和 waitgroup 的 goroutine 运行时的疑问》，这篇文章主要会讲到等等知识点，不知道大家对其都有多少了解，下面我们就一起来看一吧！当然，非常希望大家能多多评论，给出合理的建议，我们一起学习，一起进步！

请解释为什么订阅函数中有一个 groutinerunning waitgroup 以及为什么需要它。

package main

import (
    "fmt"
    "sync"
)

func main() {
    type Button struct {
        Clicked *sync.Cond
    }

    button := Button{Clicked: sync.NewCond(&sync.Mutex{})}

    subscribe := func(c *sync.Cond, fn func()) {
        var goroutineRunning sync.WaitGroup
        goroutineRunning.Add(1)
        go func() {
            goroutineRunning.Done()
            c.L.Lock()
            defer c.L.Unlock()
            c.Wait()
            fn()
        }()
        goroutineRunning.Wait()
    }

    var clickRegistered sync.WaitGroup
    clickRegistered.Add(3)

    subscribe(button.Clicked, func() {
        fmt.Println("Maximizing window.")
        clickRegistered.Done()
    })

    subscribe(button.Clicked, func() {
        fmt.Println("Displaying annoying dialog box!")
        clickRegistered.Done()
    })

    subscribe(button.Clicked, func() {
        fmt.Println("Mouse clicked.")
        clickRegistered.Done()
    })

    button.Clicked.Broadcast()
    clickRegistered.Wait()
}

当我删除函数内的等待组时，我希望代码仍然可以工作。

正确答案

如果没有 goroutinerunning 等待组，则在调用 button.clicked.broadcast() 之前，goroutine 实际上不会被调度。 broadcast() 正在通知当前正在等待条件的所有 goroutine，该条件为“无”。然后，goroutine 之后被调度，并且正在锁定..所以你会遇到死锁。

在不考虑 sync.cond 是否是问题的正确解决方案的情况下，几乎任何确保在条件锁定之前调度 goroutine 的方法都应该有效。

例如（参见 playground）：

    subscribe := func(c *sync.cond, fn func()) {
        go func() {
            c.l.lock()
            defer c.l.unlock()
            c.wait()
            fn()
        }()

        // schedule the goroutine to ensure the lock happens before returning.
        // this sort of works because of the fifo run queues, but might
        // still be susceptible to race hazards 
        runtime.gosched()
    }

您真正想要确保的是锁定确实发生了，所以可能这样的事情实际上更安全：

    subscribe := func(c *sync.Cond, fn func()) {
        var isLocked sync.WaitGroup
        isLocked.Add(1)
        go func() {
            c.L.Lock()
            isLocked.Done()

            defer c.L.Unlock()
            c.Wait()
            fn()
        }()
        isLocked.Wait()
    }

这感觉有点混乱，但希望能够清楚地说明删除等待组时实际出了什么问题。

以上就是《解答带有 cond 和 waitgroup 的 goroutine 运行时的疑问》的详细内容，更多关于的资料请关注golang学习网公众号！