Go sync/atomic.Bool CompareAndSwap 怎么做一次性状态切换:竞态判断与失败重试边界
一次性初始化、只允许一个 goroutine 刷新缓存,或者只执行一次迁移,都可以用 atomic.Bool.CompareAndSwap 把“检查当前状态”和“切换到已占用”合成一个原子动作。调用返回 true 说明当前 goroutine 抢到了执行权,返回 false 则说明别的 goroutine 已经先切换了状态;失败分支应根据业务决定跳过、等待或稍后重试,不能把失败误当成异常。
CompareAndSwap(false, true)适合做一次性门闩:只有观察到当前值确实是false的调用能把它改成true,其余调用都会走失败分支。
- CAS 的比较和写入是一个不可拆开的原子步骤。
- 成功只代表拿到一次执行权,不代表业务函数已经成功。
- 不要复制已经使用过的
atomic.Bool;多进程场景也不能靠它做全局锁。
先从一次重复初始化现场看结果
假设服务启动时有多个 goroutine 同时触发 initCache。普通的“先 Load、再 Store”会把判断和写入拆开,两个调用都可能看到 false。CompareAndSwap(false, true) 则把竞争压缩到一个原子状态转换。
package main
import (
"fmt"
"sync"
"sync/atomic"
)
type CacheInit struct {
started atomic.Bool
}
func (c *CacheInit) initCache(id int) {
if !c.started.CompareAndSwap(false, true) {
fmt.Println(id, "skip")
return
}
fmt.Println(id, "initialize")
}
func main() {
var c CacheInit
var wg sync.WaitGroup
for id := 1; id
两次输出的顺序不固定,但只有一次会打印 initialize,另一次会打印 skip。这里的成功路径是“抢到门闩后执行初始化”,不是“CAS 自动完成初始化”;业务函数仍然需要自己处理返回值和错误。
沿着 CompareAndSwap 的真实状态路径排查
代码里的节点很少:initCache 读取 started,调用 CompareAndSwap(false, true),再分流到 skip 或 initialize。CAS 失败时并不会把状态改回去,也不会自动排队等待。

图中 initCache、started、CompareAndSwap(false, true)、initialize 和 skip 都来自本节代码。若初始化函数返回错误,状态已经是 true,下一次调用不会自动重试,这正是一次性门闩和可重试任务的边界。
先确认失败是竞争,还是业务失败
排查时先把结果分成两类。CompareAndSwap(false, true) 返回 false,表示当前值不是期望的 false,通常意味着别人已经抢先;它不是初始化函数的错误。相反,CAS 返回 true 后,initialize 仍可能因为网络、磁盘或配置校验失败而出现 业务错误。

| 观察结果 | 状态变化 | 处理建议 |
|---|---|---|
| CAS 返回 false | 没有获得执行权 | 按场景跳过、等待已有人完成,或安排明确重试 |
| CAS 返回 true,initialize 成功 | false → true | 继续使用已完成的资源 |
| CAS 返回 true,initialize 失败 | 仍为 true | 设计回滚或把状态模型改成可表达失败/重试 |
需要重试时,不要盲目重复 Store
如果业务要求初始化失败后可以再来一次,直接在错误分支调用 started.Store(false) 要谨慎:它可能把已经由其他逻辑依赖的“已开始”状态重新打开。更稳妥的做法是把状态扩展为带版本或结果的状态机,或者让一个拥有明确责任的协调者决定何时重置。
如果只是“同一时刻只允许一个刷新任务”,可以把状态清理放进成功或失败都必达的收尾路径,但要确认并发调用不会在旧任务释放后误读半成品。atomic.Bool 只保护这个布尔状态,不能替代对缓存内容本身的同步。
三个容易误判的边界
- 把 CAS 当作互斥锁:它只提供一次状态转换,不会保护后续任意多步操作;复杂临界区应考虑
sync.Mutex。 - 复制结构体:
CacheInit中含有atomic.Bool,第一次使用后不要复制CacheInit,也不要按值传递它。 - 跨进程共享:两个进程各自拥有自己的
started,它们仍可能同时初始化;跨进程唯一性需要外部存储或协调服务。
相关问题
CAS 返回 false 要不要立刻重试?
不一定。若任务允许合并或跳过,直接返回即可;若必须完成,应等待明确的完成信号,而不是高速循环 CAS。
初始化失败后为什么不能自然重试?
因为成功抢到执行权时已经完成了 false → true,CAS 不知道后面的 initialize 是否成功。重试需要另一个可验证的状态模型。
atomic.Bool 能保护多个字段吗?
不能。它只原子地表达一个布尔状态,多个字段的一致性仍需要锁、消息传递或不可变快照。
最后用返回值做决定
看到 CompareAndSwap(false, true) 时,先问清楚它保护的是“只允许一次”还是“当前只允许一个”。前者可以在成功后保持 true,后者必须设计可证明的释放与重试路径。CAS 解决的是竞争窗口,不会替你完成业务事务。
MySQL 插入或更新后怎么拿到已有主键:LAST_INSERT_ID(id) 与并发验收
- 上一篇
- MySQL 插入或更新后怎么拿到已有主键:LAST_INSERT_ID(id) 与并发验收
- 下一篇
- Redis LMPOP 怎么按需批量取队列:COUNT、方向与空队列判断
-
- Golang · Go问答 | 2天前 | 并发 · go · 初始化 · Go 初始化错误 sync.OnceValue 并发排障
- OnceValue 初始化错误缓存后的恢复策略
- 500浏览 收藏
-
- Golang · Go问答 | 2天前 | 并发 · go · Go sync.RWMutex 并发排障 读锁升级
- RWMutex 写锁升级导致阻塞时的改造方案
- 395浏览 收藏
-
- Golang · Go问答 | 2天前 | 并发 · go · Go sync.Mutex 指针接收者 copylocks 并发排障
- sync.Mutex 复制后出现异常解锁的结构体设计
- 448浏览 收藏
-
- Golang · Go问答 | 2天前 | 并发 · go · Go wait add sync.WaitGroup Done 并发收尾 WaitGroup.Go
- WaitGroup Go 方法调用顺序的并发收尾
- 455浏览 收藏
-
- Golang · Go问答 | 2天前 | 并发 · go · Context · Go context Context.Value WithValue
- context.WithValue 键类型冲突导致字段覆盖的规避
- 277浏览 收藏
-
- Golang · Go问答 | 2天前 |
- context.Cause 区分主动取消与超时取消
- 485浏览 收藏
-
- Golang · Go问答 | 2天前 | go ·
- context.AfterFunc 回调未执行时的取消时序
- 342浏览 收藏
-
- Golang · Go问答 | 2天前 |
- HTTP Trailer 读取为空时的响应头声明顺序
- 448浏览 收藏
-
- Golang · Go问答 | 2天前 |
- HTTP 服务器读取请求体超时的连接处理
- 290浏览 收藏
-
- Golang · Go问答 | 2天前 |
- net/http 客户端关闭连接后请求体重用的限制
- 497浏览 收藏
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 543次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 516次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 500次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 485次学习
-
- PubMedQA
- 深入了解PubMedQA生物医学问答数据集,涵盖其核心功能、使用方法及在临床决策、药物研发等场景的应用,助力提升NLP模型性能。
- 445次使用
-
- H2O EvalGPT
- H2O EvalGPT是H2O.ai推出的开源LLM评估平台,提供详细的大模型性能排行榜、行业特定基准测试及A/B测试功能,助您快速选择最适合项目的高性能大语言模型。
- 517次使用
-
- LMArena
- LMArena是加州大学伯克利分校推出的AI模型匿名评测平台。通过盲测投票机制,用户可对比不同大模型回答并生成实时排行榜,助力开发者优化模型及用户选择最佳AI工具。
- 532次使用
-
- HELM
- 深入了解斯坦福推出的HELM(Holistic Evaluation of Language Models)大模型评测体系。本文解析其核心功能、安装配置步骤及应用场景,涵盖准确性、公平性、鲁棒性等多维度指标,助力开发者全面优化语言模型性能。
- 478次使用
-
- MMBench
- MMBench是由上海人工智能实验室等机构联合推出的多模态基准测试平台,提供细粒度能力评估、大规模数据集及VLMEvalKit工具。本文详细介绍其核心功能、安装使用方法及应用场景,助力开发者全面评估多模态模型性能。
- 301次使用
-
- GScript 编写标准库示例详解
- 2022-12-30 369浏览
-
- 关于Golang标准库flag的全面讲解
- 2023-02-25 344浏览
-
- Golang标准库unsafe源码解读
- 2022-12-29 464浏览
-
- 快速掌握Go语言HTTP标准库的实现方法
- 2022-12-30 327浏览
-
- SingleFlight模式的Go并发编程学习
- 2023-01-01 285浏览

