0

0

如何使用Golang条件变量实现协程同步_协调复杂并发流程

P粉602998670

P粉602998670

发布时间:2026-01-03 15:13:03

|

797人浏览过

|

来源于php中文网

原创

Go语言通过sync.Cond结合互斥锁模拟条件变量,用于goroutine间等待条件成立,需用for循环防范虚假唤醒,典型场景如生产者-消费者;相比channel,它适合多协程等待同一条件或需细粒度唤醒控制。

如何使用golang条件变量实现协程同步_协调复杂并发流程

Go 语言本身不提供传统意义上的“条件变量”(如 pthread_cond_t),但可以通过 sync.Cond 结合互斥锁(sync.Mutexsync.RWMutex)模拟出等效行为,用于在多个 goroutine 之间等待某个条件成立后再继续执行。它适用于需要“唤醒等待中协程”的场景,比如生产者-消费者、任务依赖、资源就绪通知等。

理解 sync.Cond 的核心机制

sync.Cond 不是独立的同步原语,它必须绑定一个互斥锁,所有对条件的检查和等待都必须在该锁保护下进行。它的关键方法有:

  • Wait():释放锁并挂起当前 goroutine,直到被 Signal() 或 Broadcast() 唤醒;被唤醒后会自动重新获取锁,再返回
  • Signal():唤醒一个正在 Wait() 的 goroutine(若有)
  • Broadcast():唤醒所有正在 Wait() 的 goroutine

⚠️ 注意:Wait() 前必须已持有锁;每次 Wait() 返回后,条件可能已改变,因此必须用 for 循环检查条件是否真正满足(即“虚假唤醒”需防范)。

典型用法:生产者-消费者模型

假设有一个共享缓冲区,多个生产者往里塞数据,多个消费者从中取数据。消费者不能在空时取,生产者不能在满时塞。

立即学习go语言免费学习笔记(深入)”;

Sora
Sora

Sora是OpenAI发布的一种文生视频AI大模型,可以根据文本指令创建现实和富有想象力的场景。

下载
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 是合理补充。

相关专题

更多
golang如何定义变量
golang如何定义变量

golang定义变量的方法:1、声明变量并赋予初始值“var age int =值”;2、声明变量但不赋初始值“var age int”;3、使用短变量声明“age :=值”等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

177

2024.02.23

golang有哪些数据转换方法
golang有哪些数据转换方法

golang数据转换方法:1、类型转换操作符;2、类型断言;3、字符串和数字之间的转换;4、JSON序列化和反序列化;5、使用标准库进行数据转换;6、使用第三方库进行数据转换;7、自定义数据转换函数。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

225

2024.02.23

golang常用库有哪些
golang常用库有哪些

golang常用库有:1、标准库;2、字符串处理库;3、网络库;4、加密库;5、压缩库;6、xml和json解析库;7、日期和时间库;8、数据库操作库;9、文件操作库;10、图像处理库。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

336

2024.02.23

golang和python的区别是什么
golang和python的区别是什么

golang和python的区别是:1、golang是一种编译型语言,而python是一种解释型语言;2、golang天生支持并发编程,而python对并发与并行的支持相对较弱等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

206

2024.03.05

golang是免费的吗
golang是免费的吗

golang是免费的。golang是google开发的一种静态强类型、编译型、并发型,并具有垃圾回收功能的开源编程语言,采用bsd开源协议。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

388

2024.05.21

golang结构体相关大全
golang结构体相关大全

本专题整合了golang结构体相关大全,想了解更多内容,请阅读专题下面的文章。

194

2025.06.09

golang相关判断方法
golang相关判断方法

本专题整合了golang相关判断方法,想了解更详细的相关内容,请阅读下面的文章。

189

2025.06.10

golang数组使用方法
golang数组使用方法

本专题整合了golang数组用法,想了解更多的相关内容,请阅读专题下面的文章。

191

2025.06.17

php源码安装教程大全
php源码安装教程大全

本专题整合了php源码安装教程,阅读专题下面的文章了解更多详细内容。

194

2025.12.31

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Go 教程
Go 教程

共32课时 | 3.3万人学习

Go语言实战之 GraphQL
Go语言实战之 GraphQL

共10课时 | 0.8万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号