Go语言通过sync.Cond结合互斥锁模拟条件变量，用于goroutine间等待条件成立，需用for循环防范虚假唤醒，典型场景如生产者-消费者；相比channel，它适合多协程等待同一条件或需细粒度唤醒控制。
Go 语言本身不提供传统意义上的“条件变量”（如 pthread_cond_t），但可以通过 sync.Cond 结合互斥锁（sync.Mutex 或 sync.RWMutex）模拟出等效行为，用于在多个 goroutine 之间等待某个条件成立后再继续执行。它适用于需要“唤醒等待中协程”的场景，比如生产者-消费者、任务依赖、资源就绪通知等。
理解 sync.Cond 的核心机制
sync.Cond 不是独立的同步原语，它必须绑定一个互斥锁，所有对条件的检查和等待都必须在该锁保护下进行。它的关键方法有：
- Wait()：释放锁并挂起当前 goroutine，直到被 Signal() 或 Broadcast() 唤醒；被唤醒后会自动重新获取锁，再返回
- Signal()：唤醒一个正在 Wait() 的 goroutine（若有）
- Broadcast()：唤醒所有正在 Wait() 的 goroutine
⚠️ 注意：Wait() 前必须已持有锁；每次 Wait() 返回后，条件可能已改变，因此必须用 for 循环检查条件是否真正满足（即“虚假唤醒”需
防范）。
典型用法：生产者-消费者模型
假设有一个共享缓冲区，多个生产者往里塞数据，多个消费者从中取数据。消费者不能在空时取，生产者不能在满时塞。
var (
mu sync.Mutex
cond = sync.NewCond(&mu)
buffer = make([]int, 0, 10)
maxSize = 10
)
// 消费者
func consumer(id int) {
for {
mu.Lock()
for len(buffer) == 0 {
cond.Wait() // 等待非空
}
x := buffer[0]
buffer = buffer[1:]
mu.Unlock()
fmt.Printf("consumer %d got %d\n", id, x)
time.Sleep(time.Millisecond * 100)
}
}
// 生产者
func producer(id int) {
for i := 0; i < 5; i++ {
mu.Lock()
for len(buffer) == maxSize {
cond.Wait() // 等待未满
}
buffer = append(buffer, i+id10)
fmt.Printf("producer %d put %d\n", id, buffer[len(buffer)-1])
cond.Signal() // 通知一个消费者
mu.Unlock()
time.Sleep(time.Millisecond 50)
}
}
这里的关键点是：条件检查必须在锁内完成，且用 for 循环包裹 Wait()；Signal() 在锁内调用更安全（避免唤醒丢失）。
避免常见陷阱
以下错误容易导致死锁或逻辑异常：
- 在没有锁的情况下调用 Wait()：panic
- Wait() 后不重检条件：可能因虚假唤醒或竞争而读到无效状态
- Signal() / Broadcast() 在锁外调用：可能唤醒正在加锁的 goroutine，造成唤醒丢失（虽不 panic，但逻辑错乱）
- 用普通变量代替 cond 通知：无法阻塞 goroutine，只能轮询，浪费 CPU
替代方案与权衡
在多数 Go 场景中，channel 更推荐作为协程通信首选，例如用带缓冲 channel 实现生产者-消费者，天然支持阻塞、容量控制和关闭语义。而 sync.Cond 更适合以下情况：
- 多个 goroutine 等待同一条件（如“所有子任务完成”、“文件加载完毕”）
- 需要细粒度唤醒控制（Signal vs Broadcast）
- 已有共享状态结构，且不希望为每个条件都建 channel
若只是简单协同，优先选 channel；若需复用锁保护的状态 + 条件等待，sync.Cond 是合理补充。
