首页 >  Golang >  Go问答

Go sync.Cond Wait 为什么要循环检查条件

来源:17golang原创

时间:2026-10-28 21:45:23 359浏览 收藏

先记住一个结论:sync.Cond.Wait() 返回,只说明当前 goroutine 被唤醒并重新拿到了关联的 Locker;它不保证共享条件仍然为真。因此,等待条件必须写成 for 循环,而不是只判断一次的 if。

官方地址:https://pkg.go.dev/sync#Cond.Wait

把“有人通知我了”和“我现在可以继续工作了”分开判断,才是使用条件变量的关键。

理解 Wait 返回时发生了什么

Cond 关联一把锁和一个共享条件。调用 Wait 前,调用方应先持有这把锁;Wait 会原子地释放锁并挂起当前 goroutine,稍后被 Signal 或 Broadcast 唤醒,再重新拿到锁后返回。

这里有三个容易混为一谈的时刻:等待者释放了锁、等待者收到了唤醒、等待者重新拿到锁。唤醒发生后,其他 goroutine 可能已经先拿到锁并改变了共享状态,所以返回时只能重新读取条件,不能沿用进入等待前的判断。

sync.Cond、Locker、Wait 与共享条件之间关系的静态说明图
图1:结构说明图,展示 Wait、Locker 与共享条件的关系;被唤醒不等于条件自动成立,不是运行截图。

为什么 if 判断不够,应该改成 for

下面这个写法把一次唤醒误当成了条件成立:

// 错误示例:唤醒后没有重新确认队列是否仍有数据
mu.Lock()
if len(queue) == 0 {
    notEmpty.Wait()
}
item := queue[0] // 这里可能仍然没有可取元素
queue = queue[1:]
mu.Unlock()

例如有多个消费者同时等待,生产者放入一个元素后广播;第一个消费者拿到锁并取走元素,第二个消费者随后也被唤醒。第二个消费者虽然确实收到通知,但队列已经重新为空。即使没有操作系统意义上的“虚假唤醒”,这个竞争窗口也足以让 if 失效。

正确模板是把条件判断放回循环:

// 正确示例:每次重新拿到锁后,都用当前共享状态复查条件
mu.Lock()
for len(queue) == 0 {
    notEmpty.Wait()
}
item := queue[0]
queue = queue[1:]
mu.Unlock()

循环不是为了“多等几次”,而是把唤醒当成重新检查的机会。只有条件真的满足,代码才进入取值或修改共享状态的分支。

让条件读写都受同一把锁保护

条件变量本身不保存业务条件。队列是否为空、容量是否已满、任务是否可领取,都要由调用方维护。生产者和消费者必须使用同一把锁读取与修改这些状态,并在状态变化后发送合适的通知。

// 有界队列的核心关系:条件、数据和锁必须属于同一套同步协议
mu.Lock()
for len(queue) == limit {
    notFull.Wait() // 队列满时等待生产空间
}
queue = append(queue, item)
notEmpty.Signal() // 数据从空变为可消费,唤醒一个消费者
mu.Unlock()

消费者侧则围绕 len(queue) == 0 循环等待,取出元素后通知 notFull。通知应放在共享状态已经改变之后;锁是否在调用 Signal 时持有,要遵循同一套协议,重点是条件读写不能脱离保护它的锁。

生产者、消费者、队列与 sync.Cond 条件之间关系的静态说明图
图2:关系说明图,展示生产者和消费者围绕同一把锁读写队列条件;图中关系是静态示意,不是执行结果。

遇到 Wait 相关问题时怎么排查

可以按下面四项检查,不必先怀疑 Wait 本身:

  • 锁是否一致:检查条件的读、写和 Wait 是否都围绕同一个 Locker。
  • 是否使用 for:只要返回后要依赖共享状态,就重新判断完整条件。
  • 通知时机:先修改共享状态,再调用 Signal 或 Broadcast。
  • 资源责任:确认是否真的需要 Cond;简单的一对多通知场景有时用 channel 更直接。

Go 官方文档还特别说明,Broadcast 可以类比关闭 channel,Signal 可以类比向 channel 发送;这只是帮助理解的对应关系,不意味着两者在所有场景下都能机械替换。

几个常见问题

Wait 会不会无缘无故返回?

当前 Go 文档说明,Wait 不会在没有被 Signal 或 Broadcast 唤醒时返回。但这仍不改变“返回后必须复查条件”的规则,因为其他 goroutine 可能在你重新拿锁前改变了状态。

Signal 后为什么还要重新加锁?

通知只表示有等待者获得继续竞争锁的机会,不等于通知者把锁和共享数据一并交给了它。等待者拿回锁后,仍必须读取当前状态。

什么时候可以考虑 channel?

如果需求只是传递数据、关闭广播或表达一次性的完成事件,channel 往往更容易读;当条件由多个字段组成、需要复用同一把锁并精细控制等待关系时,sync.Cond 才更有价值。

总结:Wait 负责等待与重新持锁,业务代码负责判断条件。把一次性 if 改成受同一把锁保护的 for,就能覆盖通知后状态被其他 goroutine 改变的正常竞争场景。

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