答案:Go的atomic包提供原子操作避免锁开销,支持基本类型如int32、int64的增减、比较交换、加载存储等操作,适用于计数器、状态标志和单例初始化等场景。1. 使用atomic.AddInt64可实现无锁并发计数;2. CompareAndSwap用于无锁逻辑控制,确保操作仅执行一次;3. Load/Store保证读写一致性,防止重排序。atomic适用于基础类型,提升并发性能。

在高并发编程中,数据竞争是常见问题。Golang 提供了 sync/atomic 包来支持原子操作,避免使用锁带来的性能开销。atomic 能保证对基本数据类型的读写、增减、交换等操作是不可分割的,适用于计数器、状态标志、单例初始化等场景。
atomic 支持的基本操作类型
atomic 主要支持 int32、int64、uint32、uint64、uintptr 和 unsafe.Pointer 类型。这些类型的操作包括:
增减操作:AddInt32、AddInt64 等,用于安全地增加或减少数值比较并交换(CAS):CompareAndSwapInt32、CompareAndSwapInt64 等,常用于实现无锁算法加载与存储:LoadInt32、StoreInt32 等,确保读写操作的原子性交换值:SwapInt32、SwapInt64,原子地替换变量值
典型应用场景:并发计数器
当多个 goroutine 需要更新同一个计数器时,使用 atomic.AddInt64 比 mutex 更轻量。
var counter int64func worker() {for i := 0; i < 1000; i++ {atomic.AddInt64(&counter, 1)}}
func main() {var wg sync.WaitGroupfor i := 0; i < 10; i++ {wg.Add(1)go func() {defer wg.Done()worker()}()}wg.Wait()fmt.Println("Counter:", counter) // 输出 10000}
这里无需互斥锁,atomic.AddInt64 直接完成线程安全的递增。
立即学习“go语言免费学习笔记(深入)”;
使用 CAS 实现无锁逻辑控制
CompareAndSwap 可用于实现 once 或状态切换等逻辑。例如,确保某操作只执行一次:
var initialized int32func doOnce() {if atomic.CompareAndSwapInt32(&initialized, 0, 1) {fmt.Println("Initialization done")// 执行初始化逻辑} else {fmt.Println("Already initialized")}}
多个 goroutine 同时调用 doOnce,只有第一个能成功将 initialized 从 0 改为 1。
加载与存储保证读写一致性
在频繁读写的场景下,使用 LoadInt32 和 StoreInt32 可避免脏读。
var status int32 = 1go func() {for {current := atomic.LoadInt32(&status)if current == 0 {break}time.Sleep(time.Millisecond * 100)}}()
// 外部控制关闭time.Sleep(time.Second)atomic.StoreInt32(&status, 0)
这种模式常用于信号通知或状态轮询,确保读写不会因编译器或 CPU 重排序导致异常。
基本上就这些。atomic 不适合复杂结构操作,但对于基础类型,它是提升并发性能的有效工具。正确使用能减少锁竞争,提高程序吞吐。
以上就是Golang如何使用atomic保证原子操作_Golang atomic原子操作应用实践的详细内容,更多请关注创想鸟其它相关文章!
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1428171.html
微信扫一扫
支付宝扫一扫