sync/atomic提供原子操作支持,适用于无锁并发控制。相比互斥锁,原子操作开销更小,适合计数器、状态标志等简单共享变量的读写保护。核心函数包括LoadXXX、StoreXXX、AddXXX、CompareAndSwapXXX和SwapXXX,保证操作不可中断,避免数据竞争。典型应用有:使用AddInt64实现高性能并发计数器;通过CompareAndSwapInt32控制初始化状态,防止重复执行;利用LoadPointer和StorePointer实现配置结构体的无锁热更新。这些操作需配合unsafe.Pointer处理指针类型。原子操作虽高效,但仅适用于简单场景,复杂逻辑仍需互斥锁或channel。同时要注意内存顺序和可见性问题,合理使用可减少锁竞争、提升程序吞吐。

在Go语言中,sync/atomic 提供了对基本数据类型的原子操作支持,适用于无锁场景下的高效并发控制。相比互斥锁(sync.Mutex),原子操作开销更小,适合简单共享变量的读写保护,比如计数器、状态标志等。
原子操作的核心类型与函数
sync/atomic 主要支持 int32、int64、uint32、uint64、uintptr 和指针类型的原子操作。常用操作包括:
- atomic.LoadXXX:原子读取
- atomic.StoreXXX:原子写入
- atomic.AddXXX:原子增减
- atomic.CompareAndSwapXXX:比较并交换(CAS)
- atomic.SwapXXX:原子交换
这些函数保证操作不可中断,避免多协程竞争导致的数据不一致。
典型应用场景:并发计数器
在高并发服务中,统计请求数、错误数等场景常使用原子操作代替互斥锁提升性能。
立即学习“go语言免费学习笔记(深入)”;
示例:使用 atomic.AddInt64 实现线程安全的计数器:
var counter int64func increment() { atomic.AddInt64(&counter, 1) }
func getCounter() int64 { return atomic.LoadInt64(&counter) }
多个goroutine调用 increment() 不会引发竞态,且无需加锁,性能更高。
状态标志控制:使用 CAS 避免重复执行
有时需要确保某个操作只执行一次,类似 sync.Once 的轻量实现可用 CAS 完成。
示例:通过 atomic.CompareAndSwapInt32 控制初始化逻辑:
var status int32 // 0: uninitialized, 1: initializing, 2: donefunc initialize() { for { old := atomic.LoadInt32(&status) if old == 2 { return // 已完成 } if old == 0 && atomic.CompareAndSwapInt32(&status, 0, 1) { // 执行初始化 time.Sleep(100 * time.Millisecond) atomic.StoreInt32(&status, 2) return } runtime.Gosched() // 让出CPU } }
这种模式利用CAS实现非阻塞的状态跃迁,避免重复初始化。
指针原子操作:无锁更新结构体引用
当需要频繁读取配置或状态结构体时,可结合 atomic.LoadPointer 和 atomic.StorePointer 实现无锁更新。
注意:需将结构体指针转为 unsafe.Pointer 操作。
type Config struct {
MaxConn int
Timeout time.Duration
}
var configPtr unsafe.Pointer // 指向 Config 实例
func loadConfig() Config {
return (Config)(atomic.LoadPointer(&configPtr))
}
func updateConfig(newCfg *Config) {
atomic.StorePointer(&configPtr, unsafe.Pointer(newCfg))
}
读取方始终能拿到一个完整的配置快照,写入方通过替换指针完成热更新。
基本上就这些。合理使用 sync/atomic 能有效减少锁竞争,提升程序吞吐。但要注意它只适用于简单变量操作,复杂逻辑仍需互斥锁或 channel 配合。原子操作虽高效,也需谨慎处理内存顺序和可见性问题。不复杂但容易忽略。










