当前位置：首页 > 文章列表 > Golang > Go教程 > Golangsync.Cond使用全解析

Golangsync.Cond使用全解析

2025-08-22 15:45:43 0浏览收藏

本文深入解析了 Golang 中 `sync.Cond` 条件变量的使用。`sync.Cond` 是一种强大的协程同步机制，它基于互斥锁，通过 `Wait()`、`Signal()` 和 `Broadcast()` 方法实现协程间的等待与通知。文章详细介绍了 `sync.Cond` 的核心结构和使用流程，强调了在 `Wait()` 前必须加锁，并使用 `for` 循环检查条件以避免虚假唤醒。通过一个生产者-消费者模型的示例，展示了 `sync.Cond` 在状态变化通知场景下的应用。同时，文章还对比了 `sync.Cond` 和 Channel 的适用场景，指出 `sync.Cond` 更适合需要精确控制唤醒逻辑的场景。掌握 `sync.Cond` 的使用技巧，能帮助开发者编写更高效的并发程序。

sync.Cond用于协程间同步，核心包含互斥锁、Wait()等待和Signal/Broadcast通知。使用时需先加锁，用for循环检查条件并调用Wait，其他协程修改状态后调用Signal唤醒，适用于状态变化通知场景，如生产者-消费者模型。

Golang条件变量使用 sync.Cond实践

在Go语言中，sync.Cond 是一种用于协程间同步的机制，它允许一个或多个协程等待某个条件成立，而另一个协程在条件成立后通知它们继续执行。它常用于“生产者-消费者”模型或资源就绪通知等场景。虽然 channel 更常用于协程通信，但在某些需要明确等待某个状态改变的场景下，sync.Cond 更加直观高效。

sync.Cond 的基本结构

sync.Cond 包含三个核心部分：

L (Locker): 一个互斥锁（*sync.Mutex 或 *sync.RWMutex），用于保护共享状态。
Wait(): 使当前协程等待，直到被通知。
Signal()/Broadcast(): 唤醒一个或所有等待的协程。

使用流程通常如下：

获取锁。
检查条件是否满足，不满足则调用 Wait()，Wait 会自动释放锁并阻塞。
其他协程修改状态并调用 Signal 或 Broadcast 通知。
被唤醒的协程重新获取锁，继续执行。

简单示例：等待任务就绪

下面是一个使用 sync.Cond 等待任务到来的简单示例：

package main
import (
"fmt"
"sync"
"time"
)
type TaskQueue struct {
tasks  []string
cond   *sync.Cond
}
func (q *TaskQueue) AddTask(task string) {
q.cond.L.Lock()
defer q.cond.L.Unlock()
q.tasks = append(q.tasks, task)
fmt.Println("任务添加：", task)
q.cond.Signal() // 唤醒一个等待的消费者
}
func (q *TaskQueue) GetTask() string {
q.cond.L.Lock()
defer q.cond.L.Unlock()
// 使用 for 而不是 if，防止虚假唤醒
for len(q.tasks) == 0 {
    q.cond.Wait()
}

task := q.tasks[0]
q.tasks = q.tasks[1:]
return task
}
func main() {
var mu sync.Mutex
queue := &TaskQueue{
tasks:  make([]string, 0),
cond:   sync.NewCond(&mu),
}
// 消费者协程
go func() {
    for {
        task := queue.GetTask()
        fmt.Println("处理任务：", task)
    }
}()

// 生产者协程
for i := 1; i <= 5; i++ {
    time.Sleep(1 * time.Second)
    queue.AddTask(fmt.Sprintf("任务-%d", i))
}

time.Sleep(3 * time.Second)
}

输出结果类似：

任务添加：任务-1
处理任务：任务-1
任务添加：任务-2
处理任务：任务-2
...