Go语言sync.Cond使用指南：原理、示例与避坑要点

1. 简介

sync.Cond 是 Go 标准库中的条件变量实现，专门用于在多个 goroutine 之间进行等待和通知操作。它解决了单纯的互斥锁（Mutex）无法处理“何时执行”这一问题的痛点——Mutex 只能保证同一时间只有一个 goroutine 访问临界区，而 sync.Cond 允许 goroutine 在特定条件满足前阻塞自己，并在条件具备时被唤醒。

2. 基本使用

第1步：定义锁与Cond实例

在使用 sync.Cond 时，必须关联一个实现了 sync.Locker 接口的对象（通常是 sync.Mutex）。这是为了在检查和设置条件时提供原子性。

var (
    mu   sync.Mutex
    cond *sync.Cond
)
func init() {
    // 将互斥锁与 Cond 实例绑定
    cond = sync.NewCond(&mu)
}

第2步：消费者端调用 Wait

当 goroutine 需要等待某个条件满足时，必须按照顺序：获取锁 → 循环检查条件 → 调用 Wait()。

• 获取锁： 确保对条件的读取和后续操作的原子性。
• 循环检查： 必须使用 for 而非 if。因为被唤醒后，条件可能再次发生变化（虚假唤醒或已被其他协程消费），需重新验证。
• Wait()：内部会先释放关联的锁，让出 CPU 进入休眠；当被唤醒时，它会尝试重新获取该锁，成功后才返回。

第3步：生产者端修改状态并发送信号

当另一个 goroutine 改变了共享状态，使得等待者的条件成立时，应：获取锁 → 修改状态 → 发送 Signal 或 Broadcast → 释放锁。

• Signal()：仅唤醒一个正在等待的 goroutine。适用于生产单件产品等场景。
• Broadcast()：唤醒所有正在等待的 goroutine。适用于批量任务或广播通知，需配合正确的循环逻辑使用。

完整示例：简单的生产者-消费者模型

以下代码演示了如何利用 sync.Cond 让多个消费者在任务队列为空时阻塞，并在生产者添加任务后被唤醒。

package main

import (
	"fmt"
	"sync"
	"time"
)

var (
	mu    sync.Mutex
	cond  *sync.Cond
	count int
)

func init() {
	cond = sync.NewCond(&mu)
}

// worker 模拟消费者
func worker(id int) {
	for {
		mu.Lock()
		// 循环检查：只有 count > 0 时才继续
		for count == 0 {
			cond.Wait()
		}
		// 领取任务
		count--
		fmt.Printf("worker %d: 处理了一个任务\n", id)
		mu.Unlock()
	}
}

func main() {
	// 启动多个消费者
	for i := 1; i <= 5; i++ {
		go worker(i)
	}

	// 模拟生产者
	ticker := time.NewTicker(time.Second)
	for range ticker.C {
		mu.Lock()
		count++ // 生产一个任务
		cond.Broadcast() // 唤醒所有等待的消费者
		mu.Unlock()
	}
}

3. 进阶场景：有界缓冲区队列

在生产者-消费者模式中，更常见的需求是有容量限制的缓冲区。此时需要两个条件变量：一个用于“非空”（消费者读），一个用于“非满”（生产者写）。

4.2.1 Wait方法实现

Wait方法首先调用runtime_notifyListAdd方法，将自己加入到等待队列中，然后释放锁，等待其他协程的唤醒。

func (c *Cond) Wait() {
   // 将自己放到等待队列中
   t := runtime_notifyListAdd(&c.notify)
   // 释放锁
   c.L.Unlock()
   // 等待唤醒
   runtime_notifyListWait(&c.notify, t)
   // 重新获取锁
   c.L.Lock()
}

4.2.2 Singal方法实现

Singal方法调用runtime_notifyListNotifyOne唤醒等待队列中的一个协程。

func (c *Cond) Signal() {
   // 唤醒等待队列中的一个协程
   runtime_notifyListNotifyOne(&c.notify)
}

4.2.3 Broadcast方法实现

Broadcast方法调用runtime_notifyListNotifyAll唤醒所有处于等待状态的协程。

func (c *Cond) Broadcast() {
   // 唤醒等待队列中所有的协程
   runtime_notifyListNotifyAll(&c.notify)
}

5. 使用注意事项

5.1 务必遵循“先加锁，再Wait”的顺序

如果在调用 Wait() 之前没有获取关联的锁，将会导致运行时 panic（fatal error: sync: unlock of unlocked mutex）。这是因为 Wait() 的内部实现包含了解锁操作，若当前无锁可解，程序便会崩溃。

5.2 避免“惊群效应”与条件失效

使用 Broadcast 唤醒所有协程时，必须确保所有被唤醒的协程都能判断出自己是否真正应该继续执行。否则，大量协程同时竞争有限的资源会导致性能急剧下降甚至死锁。

5.3 唤醒后必须重新判断条件

很多初学者误用 if condition { cond.Wait() }。如果存在多个生产者同时唤醒消费者，第一个消费者消费完数据后，第二个消费者醒来时发现数据已为空，若不重新判断就会引发逻辑错误或 Panic。因此始终使用 for !condition() { cond.Wait() } 范式。

6. 总结

以上就是 Go 语言 sync.Cond 的基本使用及原理解析的全部内容。sync.Cond 虽然不如 Channel 简洁易用，但在构建复杂的状态机或高性能内存池等场景中，它能提供更细粒度的控制。掌握它的关键在于牢记：Condition + Lock + For-Check Loop 这个铁三角模式。

更多关于Go语言sync.Cond原理的资料请关注本站其它相关文章！