使用原子操作可避免锁开销,适用于计数器、状态标志等简单共享变量的并发读写,通过atomic.AddInt64等函数实现高效无锁递增,提升高并发场景性能。

在高并发场景下,多个 goroutine 对共享变量的读写很容易引发数据竞争问题。传统做法是使用互斥锁(sync.Mutex)来保护临界区,但锁会带来上下文切换和阻塞开销。而 sync/atomic 提供了更轻量的原子操作,能有效提升性能,尤其是在只涉及简单类型读写的场景中。
atomic 包支持对整型(int32、int64)、uint32、uint64、指针、布尔等类型的原子操作。它适用于以下情况:
例如,一个服务需要统计请求数,如果用 Mutex 加锁再递增,每次都要竞争锁。而使用 atomic.AddInt64,可以直接无锁完成递增,效率更高。
atomic 提供了几类核心操作:增减、读写、比较并交换(CAS)。
立即学习“go语言免费学习笔记(深入)”;
1. 增减操作
atomic.AddInt64(&counter, 1) 可以安全地对 int64 变量加 1。同样有 AddUint32、AddInt32 等。示例:高并发计数器
var counter int64
func worker() {
for i := 0; i < 1000; i++ {
atomic.AddInt64(&counter, 1)
}
}
func main() {
var wg sync.WaitGroup
for i := 0; i < 10; i++ {
wg.Add(1)
go func() {
defer wg.Done()
worker()
}()
}
wg.Wait()
fmt.Println("Counter:", counter) // 输出 10000
}
2. 读写操作
使用 atomic.LoadInt64(&value) 和 atomic.StoreInt64(&value, newVal) 可保证读写不被中断。注意:必须始终通过 Load/Store 访问变量,否则仍可能出错。3. 比较并交换(Compare And Swap)
CAS 是实现无锁算法的核心。比如:for {
old := atomic.LoadInt64(&counter)
new := old + 1
if atomic.CompareAndSwapInt64(&counter, old, new) {
break
}
// 失败则重试,其他 goroutine 修改了值
}
这种模式适合需要条件更新的场景,比如实现自定义的原子累加或状态机转换。
在简单变量操作中,atomic 性能通常比 Mutex 高出数倍。可以通过 benchmark 验证:
func BenchmarkAtomicInc(b *testing.B) {
var counter int64
b.RunParallel(func(pb *testing.PB) {
for pb.Next() {
atomic.AddInt64(&counter, 1)
}
})
}
func BenchmarkMutexInc(b *testing.B) {
var counter int64
var mu sync.Mutex
b.RunParallel(func(pb *testing.PB) {
for pb.Next() {
mu.Lock()
counter++
mu.Unlock()
}
})
}
运行结果通常显示 atomic 版本的吞吐量更高,延迟更低。
atomic 虽快,但不是万能的。
另外,atomic.Value 可用于任意类型的原子存储,但需确保类型一致且首次写入后不再修改类型。
基本上就这些。在合适场景下用好 sync/atomic,能显著减少锁竞争,提升程序吞吐。关键是理解其边界,避免误用。性能优化不总是靠加锁解决,有时候“无锁”才是更快的路。
以上就是如何在 Golang 中使用原子操作优化性能_Golang sync/atomic 应用实战的详细内容,更多请关注php中文网其它相关文章!
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号