golang-条件变量发送通知接受通知广播

3个指针方法:

    Wait()  等待goroutine 等待接受通知,Single() Broadcast() 解除阻塞
    Single() 发送通知,如果存在多个goroutine,只会任意选择一个
    Broadcast() 广播 方法给所有人

下面时wait方法底层执行流程

  1. 尝试解锁
  2. wait 尝试解锁,解完锁之后等待其他给发通知,===> 进入了阻塞状态,等待被唤醒: single(),broadcast()
  3. 一旦被唤醒后,又会锁定
func (c *Cond) Wait() {
    c.checker.check()
    t := runtime_notifyListAdd(&c.notify)
    c.L.Unlock()
    runtime_notifyListWait(&c.notify, t)
    c.L.Lock()
}

操作案例:

sync.Cond

评论

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

这个站点使用 Akismet 来减少垃圾评论。了解你的评论数据如何被处理