Go sync-atomic原子操作详解从CAS到无锁并发数据结构文章导语Mutex提供互斥访问但锁的开销在高并发场景下可能成为瓶颈。Go的sync/atomic包提供了硬件级别的原子操作是实现无锁数据结构和高性能并发算法的基础。本文将深入atomic包的使用和最佳实践。一、原子操作的本质原子操作由CPU指令直接支持如x86的LOCK CMPXCHGGo通过编译器的sync/atomic包暴露这些能力// atomic包操作的内存必须对齐varcounterint64// 原子加atomic.AddInt64(counter,1)// CPU保证整个过程不可中断// 普通加非原子——可能丢失更新counter// 编译为多条指令LOAD → ADD → STORE二、atomic包的完整API2.1 基本原子操作varvint32// 读取Go 1.19可省略Loadold:atomic.LoadInt32(v)// 存储Go 1.19可省略Storeatomic.StoreInt32(v,100)// 加法new:atomic.AddInt32(v,1)// 交换——返回旧值old:atomic.SwapInt32(v,200)2.2 CASCompare And Swap// CAS是最重要的原子原语funcCompareAndSwapInt32(addr*int32,old,newint32)(swappedbool)// 使用CAS实现自旋锁typeSpinLockstruct{lockedint32}func(s*SpinLock)Lock(){for!atomic.CompareAndSwapInt32(s.locked,0,1){runtime.Gosched()// 让出CPU}}func(s*SpinLock)Unlock(){atomic.StoreInt32(s.locked,0)}2.3 atomic.Value——任意类型的原子存储typeConfigstruct{Timeout time.Duration MaxConnint}varcfg atomic.Value// 存储*Config// 初始化——必须存储同类型cfg.Store(Config{Timeout:30,MaxConn:100})// 读取ifc,ok:cfg.Load().(*Config);ok{fmt.Println(c.Timeout)}// 交换——返回旧值old:cfg.Swap(Config{Timeout:60,MaxConn:200})三、实战无锁计数器// 高并发计数器——比Mutex快5-10倍typeAtomicCounterstruct{valueint64}func(c*AtomicCounter)Increment()int64{returnatomic.AddInt64(c.value,1)}func(c*AtomicCounter)Decrement()int64{returnatomic.AddInt64(c.value,-1)}func(c*AtomicCounter)Value()int64{returnatomic.LoadInt64(c.value)}func(c*AtomicCounter)Reset(){atomic.StoreInt64(c.value,0)}四、实战无锁环形队列typeRingBufferstruct{buf[]interface{}capacityuint64readIdxuint64// 原子操作writeIdxuint64// 原子操作}funcNewRingBuffer(capacityint)*RingBuffer{// capacity必须为2的幂cap:uint64(1)forcapuint64(capacity){cap1}returnRingBuffer{buf:make([]interface{},cap),capacity:cap,}}func(rb*RingBuffer)Push(iteminterface{})bool{mask:rb.capacity-1for{write:atomic.LoadUint64(rb.writeIdx)read:atomic.LoadUint64(rb.readIdx)ifwrite-readrb.capacity{returnfalse// 满}ifatomic.CompareAndSwapUint64(rb.writeIdx,write,write1){rb.buf[writemask]itemreturntrue}}}五、Go 1.19的类型化原子操作// Go 1.19之前varvint64atomic.AddInt64(v,1)// Go 1.19 类型化atomicvarv atomic.Int64 v.Add(1)v.Store(100)val:v.Load()swapped:v.CompareAndSwap(100,200)// 也支持Bool、Uint32、Uint64、Pointer等varready atomic.Bool ready.Store(true)ifready.Load(){// ...}六、全文总结atomic是硬件级别保证性能远优于MutexCAS是实现无锁数据结构的核心原语atomic.Value适合存储配置等任意类型**Go 1.19**类型化atomic更安全、易用无锁编程复杂度高仅在确实需要性能时使用七、技术进阶展望Go内存模型与Happens-Before关系原子操作在channel实现中的使用Lock-free与Wait-free算法参考文献Go sync/atomic包文档: https://pkg.go.dev/sync/atomicGo内存模型: https://go.dev/ref/memGo 1.19 Release Notes - atomic types《Go并发编程实战》第三章Go源码 sync/atomic/doc.go Go-sync-atomic原子操作详解从CAS到无锁并发数据结构
Go sync-atomic原子操作详解从CAS到无锁并发数据结构文章导语Mutex提供互斥访问但锁的开销在高并发场景下可能成为瓶颈。Go的sync/atomic包提供了硬件级别的原子操作是实现无锁数据结构和高性能并发算法的基础。本文将深入atomic包的使用和最佳实践。一、原子操作的本质原子操作由CPU指令直接支持如x86的LOCK CMPXCHGGo通过编译器的sync/atomic包暴露这些能力// atomic包操作的内存必须对齐varcounterint64// 原子加atomic.AddInt64(counter,1)// CPU保证整个过程不可中断// 普通加非原子——可能丢失更新counter// 编译为多条指令LOAD → ADD → STORE二、atomic包的完整API2.1 基本原子操作varvint32// 读取Go 1.19可省略Loadold:atomic.LoadInt32(v)// 存储Go 1.19可省略Storeatomic.StoreInt32(v,100)// 加法new:atomic.AddInt32(v,1)// 交换——返回旧值old:atomic.SwapInt32(v,200)2.2 CASCompare And Swap// CAS是最重要的原子原语funcCompareAndSwapInt32(addr*int32,old,newint32)(swappedbool)// 使用CAS实现自旋锁typeSpinLockstruct{lockedint32}func(s*SpinLock)Lock(){for!atomic.CompareAndSwapInt32(s.locked,0,1){runtime.Gosched()// 让出CPU}}func(s*SpinLock)Unlock(){atomic.StoreInt32(s.locked,0)}2.3 atomic.Value——任意类型的原子存储typeConfigstruct{Timeout time.Duration MaxConnint}varcfg atomic.Value// 存储*Config// 初始化——必须存储同类型cfg.Store(Config{Timeout:30,MaxConn:100})// 读取ifc,ok:cfg.Load().(*Config);ok{fmt.Println(c.Timeout)}// 交换——返回旧值old:cfg.Swap(Config{Timeout:60,MaxConn:200})三、实战无锁计数器// 高并发计数器——比Mutex快5-10倍typeAtomicCounterstruct{valueint64}func(c*AtomicCounter)Increment()int64{returnatomic.AddInt64(c.value,1)}func(c*AtomicCounter)Decrement()int64{returnatomic.AddInt64(c.value,-1)}func(c*AtomicCounter)Value()int64{returnatomic.LoadInt64(c.value)}func(c*AtomicCounter)Reset(){atomic.StoreInt64(c.value,0)}四、实战无锁环形队列typeRingBufferstruct{buf[]interface{}capacityuint64readIdxuint64// 原子操作writeIdxuint64// 原子操作}funcNewRingBuffer(capacityint)*RingBuffer{// capacity必须为2的幂cap:uint64(1)forcapuint64(capacity){cap1}returnRingBuffer{buf:make([]interface{},cap),capacity:cap,}}func(rb*RingBuffer)Push(iteminterface{})bool{mask:rb.capacity-1for{write:atomic.LoadUint64(rb.writeIdx)read:atomic.LoadUint64(rb.readIdx)ifwrite-readrb.capacity{returnfalse// 满}ifatomic.CompareAndSwapUint64(rb.writeIdx,write,write1){rb.buf[writemask]itemreturntrue}}}五、Go 1.19的类型化原子操作// Go 1.19之前varvint64atomic.AddInt64(v,1)// Go 1.19 类型化atomicvarv atomic.Int64 v.Add(1)v.Store(100)val:v.Load()swapped:v.CompareAndSwap(100,200)// 也支持Bool、Uint32、Uint64、Pointer等varready atomic.Bool ready.Store(true)ifready.Load(){// ...}六、全文总结atomic是硬件级别保证性能远优于MutexCAS是实现无锁数据结构的核心原语atomic.Value适合存储配置等任意类型**Go 1.19**类型化atomic更安全、易用无锁编程复杂度高仅在确实需要性能时使用七、技术进阶展望Go内存模型与Happens-Before关系原子操作在channel实现中的使用Lock-free与Wait-free算法参考文献Go sync/atomic包文档: https://pkg.go.dev/sync/atomicGo内存模型: https://go.dev/ref/memGo 1.19 Release Notes - atomic types《Go并发编程实战》第三章Go源码 sync/atomic/doc.go