sync/atomic是Go中用于无锁线程安全操作的基础工具,支持对int32、int64等基础类型的原子读写与CAS,需确保内存对齐、类型匹配,禁用结构体字段,推荐全局变量或指针声明,配合Load/Store/Add/Swap/CAS实现高效并发控制。

在 Go 中,sync/atomic 是实现无锁、线程安全计数或状态更新的核心工具,适用于高并发下对基础类型(如 int32、int64、uint32、uintptr、*unsafe.Pointer)的原子读写与修改。它比加锁更轻量,但使用有严格限制——必须确保变量地址对齐、类型匹配,且不能用于结构体或非原子类型字段。
正确声明和初始化原子变量
原子操作要求变量内存对齐,因此推荐用指针或全局变量方式声明,并避免逃逸到堆上导致对齐不可控。Go 编译器会自动保证内置原子类型(如 int64)在 64 位系统上对齐,但跨平台时建议统一用 int64 或 uint64。
- ✅ 推荐:声明为包级变量或局部指针,显式初始化
- ❌ 避免:直接对结构体字段调用原子操作(字段可能不对齐)
- ⚠️ 注意:
int不可移植(32/64 位长度不一),应改用int64
示例:
var counter int64 = 0 // 全局原子计数器var ptr unsafe.Pointer // 原子指针,可用于无锁链表或状态切换
常用原子操作及典型用途
sync/atomic 提供读、写、增减、交换、比较并交换(CAS)等操作,每种都有明确语义和适用场景。
立即学习“go语言免费学习笔记(深入)”;
-
atomic.LoadInt64(&counter):安全读取当前值,适合监控、采样 -
atomic.StoreInt64(&counter, 100):覆盖写入,常用于状态重置或配置更新 -
atomic.AddInt64(&counter, 1):线程安全自增,替代mu.Lock(); counter++; mu.Unlock() -
atomic.SwapInt64(&counter, 0):原子交换并返回旧值,适合“清零并获取”模式 -
atomic.CompareAndSwapInt64(&counter, old, new):CAS,是实现自旋锁、无锁栈/队列的基础
CAS 实现简易无锁计数器或状态机
CAS 是构建更复杂原子逻辑的基石。例如,用 CAS 实现一个只允许从 0→1 的一次性状态切换(类似 Once):
func SetOnceFlag(flag *int32) bool {return atomic.CompareAndSwapInt32(flag, 0, 1)
}
多次调用该函数,仅第一次成功返回 true,其余均返回 false,无需锁即可保证幂等性。
- CAS 循环需谨慎:避免忙等耗尽 CPU,必要时加入
runtime.Gosched() - 读取旧值应始终用
Load,不要依赖局部缓存,否则 CAS 可能失败 - 复合操作(如“读-改-写”)必须用 CAS 循环重试,而非分步调用
指针与 Unsafe.Pointer 的原子操作技巧
atomic.LoadPointer 和 atomic.StorePointer 是处理动态对象引用的关键,常见于无锁数据结构或配置热更新。
- 存储前需用
unsafe.Pointer转换,读取后需类型断言还原 - 确保被指向对象生命周期足够长(如全局变量或已逃逸对象),避免悬垂指针
- 配合
atomic.CompareAndSwapPointer可实现原子替换配置实例
示例(原子切换配置):
var configPtr unsafe.Pointeratomic.StorePointer(&configPtr, unsafe.Pointer(&newConfig))
cfg := (*Config)(atomic.LoadPointer(&configPtr))
基本上就这些。用好 sync/atomic 的关键是:选对类型、对齐可靠、避免误用结构体字段、CAS 逻辑闭环。它不是万能锁替代品,但在计数、标志位、指针切换等场景下高效又简洁。










