选择atomic而非Mutex因atomic由CPU指令支持,性能更高,适用于基本类型原子操作。示例中用atomic.AddInt64实现并发安全计数器,最终计数正确并可原子重置,避免了锁开销与数据竞争。

在Go语言中,atomic 包提供了底层的原子操作,适用于轻量级、高性能的并发场景。当我们需要实现一个并发安全的计数器时,使用 sync/atomic 比加锁(如 sync.Mutex)更高效,尤其是在读写频繁但逻辑简单的场景下。
在高并发环境下,多个goroutine同时修改同一个变量会导致数据竞争。传统做法是使用互斥锁保护共享变量:
- Mutex 加锁解锁有开销,尤其在争用激烈时性能下降明显。Go 的 sync/atomic 提供了多种原子操作函数,常用的包括:
下面是一个使用 atomic 实现的高并发计数器示例:
立即学习“go语言免费学习笔记(深入)”;
package main
<p>import (
"fmt"
"sync"
"sync/atomic"
"time"
)</p><p>func main() {
var counter int64 // 使用 int64 存储计数</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">var wg sync.WaitGroup
numGoroutines := 10
incrementsPerRoutine := 1000
// 启动多个goroutine并发增加计数
for i := 0; i < numGoroutines; i++ {
wg.Add(1)
go func() {
defer wg.Done()
for j := 0; j < incrementsPerRoutine; j++ {
atomic.AddInt64(&counter, 1) // 原子自增
}
}()
}
// 等待所有goroutine完成
wg.Wait()
// 安全读取最终值
finalCount := atomic.LoadInt64(&counter)
fmt.Printf("最终计数值: %d\n", finalCount)
// 验证是否正确
expected := int64(numGoroutines * incrementsPerRoutine)
if finalCount == expected {
fmt.Println("✅ 计数正确")
} else {
fmt.Printf("❌ 计数错误,期望 %d,实际 %d\n", expected, finalCount)
}
// 演示原子写入
time.Sleep(time.Millisecond * 10)
atomic.StoreInt64(&counter, 0)
fmt.Printf("重置后计数值: %d\n", atomic.LoadInt64(&counter))}
输出结果:
最终计数值: 10000 ✅ 计数正确 重置后计数值: 0
虽然 atomic 高效,但在使用时仍需注意以下几点:
sync.Mutex。int64 并对其取地址操作,避免内存对齐问题(尤其是32位系统上 int64 原子操作要求对齐)。可以使用 go run -race 来检测数据竞争问题:
go run -race main.go
基本上就这些。atomic 是构建高性能并发程序的重要工具之一,合理使用能让代码既安全又高效。对于简单的计数、状态标记、标志位等场景,优先考虑 atomic 而不是锁。不复杂但容易忽略细节,掌握它对提升Go编程能力很有帮助。
以上就是Golang如何使用atomic实现并发计数_Golang atomic并发计数实践详解的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号