• 源码剖析

    这一次,彻底搞懂 Go Cond-LMLPHP

    这一次,彻底搞懂 Go Cond-LMLPHP

    这一次,彻底搞懂 Go Cond-LMLPHP

    sync.Cond 排队动图

    cond.Wait 是阻塞的吗?是如何阻塞的?

    是阻塞的。不过不是 sleep 这样阻塞的。

    调用 goparkunlock 解除当前 goroutine 的 m 的绑定关系,将当前 goroutine 状态机切换为等待状态。等待后续 goready 函数时候能够恢复现场。

    cond.Signal 是如何通知一个等待的 goroutine ?

    cond.Broadcast 是如何通知等待的 goroutine 的?

    cond.Wait本身就是阻塞状态,为什么 cond.Wait 需要在循环内 ?

    我们能注意到,调用 cond.Wait 的位置,使用的是 for 的方式来调用 wait 函数,而不是使用 if 语句。

    这是由于 wait 函数被唤醒时,存在虚假唤醒等情况,导致唤醒后发现,条件依旧不成立。因此需要使用 for 语句来循环地进行等待,直到条件成立为止。

    使用中注意点

    1. 不能不加锁直接调用 cond.Wait

    func (c *Cond) Wait() {
     c.checker.check()
     t := runtime_notifyListAdd(&c.notify)
     c.L.Unlock()
     runtime_notifyListWait(&c.notify, t)
     c.L.Lock()
    }

    我们看到 Wait 内部会先调用 c.L.Unlock(),来先释放锁。如果调用方不先加锁的话,会触发“fatal error: sync: unlock of unlocked mutex”。关于 mutex 的使用方法,推荐阅读下《这可能是最容易理解的 Go Mutex 源码剖析》

    2. 为什么不能 sync.Cond 不能复制 ?

    sync.Cond 不能被复制的原因,并不是因为 sync.Cond 内部嵌套了 Locker。因为 NewCond 时传入的 Mutex/RWMutex 指针,对于 Mutex 指针复制是没有问题的。

    主要原因是 sync.Cond 内部是维护着一个 notifyList。如果这个队列被复制的话,那么就在并发场景下导致不同 goroutine 之间操作的 notifyList.wait、notifyList.notify 并不是同一个,这会导致出现有些 goroutine 会一直堵塞。

    这里留下一个问题,sync.Cond 内部是有一段代码 check sync.Cond 是不能被复制的,下面这段代码能触发这个 panic 吗?

    package main

    import (
     "fmt"
     "sync"
    )

    func main() {
     cond1 := sync.NewCond(new(sync.Mutex))
     cond := *cond1
     fmt.Println(cond)
    }

    有兴趣的可以动手尝试下,以及尝试下如何才能触发这个panic "sync.Cond is copied” 。

    sync.Cond 的剖析到这里基本就结束了。有什么想跟我交流的,欢迎评论区留言。


    欢迎关注我的公众号,随时关注我的动态

    sync.Cond 完整流程图获取链接:链接:https://pan.baidu.com/s/1DjtfCyCua0nGYB6TOSsYWA  密码: wn02。其他模块流程图,请关注公众号回复1获取。

    学习资料分享,关注公众号回复指令:

    本文分享自微信公众号 - HHFCodeRv(hhfcodearts)。
    如有侵权,请联系 [email protected] 删除。
    本文参与“OSC源创计划”,欢迎正在阅读的你也加入,一起分享。

    04-27 12:05