如何使用Golang实现并发安全计数器_Golang sync/atomic原子操作方法
技术百科
P粉602998670
发布时间:2026-01-24
浏览: 次 不能直接用 int 类型做并发计数,因为 i++ 非原子,包含读取、加1、写回三步,多 goroutine 竞争会导致丢失更新;sync/atomic 提供 Add、Load、Store、CAS 等位宽明确的原子操作,Go 1.19+ 推荐使用 atomic.Int64 封装安全计数器。
为什么不能直接用 int 类型做并发计数
多个 goroutine 同时对一个普通 int 变量执行 ++ 或 --,结果大概率出错。因为 i++ 实际包含三步:读取、加 1、写回,中间可能被其他 goroutine 插入修改,导致丢失更新。这不是“偶尔出错”,而是只要并发足够高,就一定会复现。
sync/atomic 提供哪些原子操作函数
sync/atomic 对 int32、int64、uint32、uint64、uintptr 和指针类型提供原子读写与运算。最常用的是:
-
atomic.AddInt32(&i, 1)—— 原子加,返回新值 -
atomic.LoadInt32(&i)—— 原
子读,避免编译器/CPU 重排序
-
atomic.StoreInt32(&i, 10)—— 原子写 -
atomic.CompareAndSwapInt32(&i, old, new)—— CAS,成功返回 true
注意:没有 atomic.AddInt,必须显式指定位宽(int32 或 int64),否则编译报错。
完整可运行的并发安全计数器示例
下面是一个基于 atomic.Int64(Go 1.19+ 推荐)的计数器封装,比裸用 atomic.AddInt64 更安全、更易复用:
立即学习“go语言免费学习笔记(深入)”;
package main
import (
"fmt"
"sync"
"sync/atomic"
"time"
)
type Counter struct {
v atomic.Int64
}
func (c *Counter) Inc() int64 {
return c.v.Add(1)
}
func (c *Counter) Load() int64 {
return c.v.Load()
}
func main() {
var wg sync.WaitGroup
var counter Counter
for i := 0; i < 100; i++ {
wg.Add(1)
go func() {
defer wg.Done()
for j := 0; j < 1000; j++ {
counter.Inc()
}
}()
}
wg.Wait()
fmt.Println("Final count:", counter.Load()) // 总是输出 100000
}
如果你还在用 Go atomic.AddInt64(&v, 1) 替代 c.v.Add(1),原理相同,只是 API 更底层。
容易踩的坑和性能提示
原子操作不是万能锁替代品,用错反而引入隐蔽 bug:
- 别对局部变量或栈上变量取地址传给
atomic函数——地址无效,行为未定义 -
atomic.Load*和atomic.Store*是内存屏障,但不保证临界区逻辑原子性(比如“先读再算再写”仍需锁) - 频繁调用
atomic.LoadInt64本身开销极小,但若在 tight loop 中反复读同一变量,现代 CPU 通常会缓存该 cacheline,实际性能影响不大 - 如果计数器需要支持 reset、min/max 比较等复杂逻辑,
atomic不够用,应考虑sync.Mutex封装
真正要注意的,是位宽匹配和变量生命周期——这两点出错,程序不会 panic,但结果不可预测。
# ai
# 的是
# 是一个
# 如果你
# 还在
# 多个
# 推荐使用
# 要注意
# 三步
# go
# golang
# 并发
# int
# 指针
# 为什么
# 栈
# bug
# 封装
# 指针类型
# 这不是
# 局部变量
# 位宽
相关栏目:
<?muma
$count = M('archives')->where(['typeid'=>$field['id']])->count();
?>
【
AI推广<?muma echo $count; ?>
】
<?muma
$count = M('archives')->where(['typeid'=>$field['id']])->count();
?>
【
SEO优化<?muma echo $count; ?>
】
<?muma
$count = M('archives')->where(['typeid'=>$field['id']])->count();
?>
【
技术百科<?muma echo $count; ?>
】
<?muma
$count = M('archives')->where(['typeid'=>$field['id']])->count();
?>
【
谷歌推广<?muma echo $count; ?>
】
<?muma
$count = M('archives')->where(['typeid'=>$field['id']])->count();
?>
【
百度推广<?muma echo $count; ?>
】
<?muma
$count = M('archives')->where(['typeid'=>$field['id']])->count();
?>
【
网络营销<?muma echo $count; ?>
】
<?muma
$count = M('archives')->where(['typeid'=>$field['id']])->count();
?>
【
案例网站<?muma echo $count; ?>
】
<?muma
$count = M('archives')->where(['typeid'=>$field['id']])->count();
?>
【
精选文章<?muma echo $count; ?>
】
相关推荐
- Win11怎么关闭搜索历史_Win11清除任务栏搜
- LINUX如何开放防火墙端口_Linux fire
- phpstudy本地环境mysql忘记密码_重置m
- Win11怎么看电池循环次数_Win11笔记本电池
- Win11怎么设置声音输出设备_Windows11
- Python对象比较与排序_魔术方法解析【教程】
- c++怎么编写动态链接库dll_c++ __dec
- 如何在 Go 中调用动态链接库(.so)中的函数
- Win11怎么设置开机密码_Windows11账户
- Windows10系统怎么查看系统版本_Win10
- Windows10如何重置此电脑_Windows1
- php订单日志怎么记录评价_php记录订单评价日志
- 如何使用Golang实现RPC序列化与反序列化_G
- 如何在Golang中实现并发消息队列消费者_Gol
- Python网络异常模拟_测试说明【指导】
- Windows 11如何开启文件夹加密(EFS)_
- 如何优化Golang Web性能_Golang H
- Win11怎么压缩文件 Win11自带压缩解压功能
- Win10怎样设置多显示器_Win10多显示器扩展
- 如何更改Windows资源管理器的默认启动位置?(
- Win11怎么开启HDR模式_Windows 11
- 如何自定义Windows终端的默认配置文件?(Po
- Windows10如何更改桌面图标间距_Win10
- c++ try_emplace用法_c++ map
- Win11文件扩展名怎么显示 Win11查看文件后
- Drupal 中渲染节点时出现 HTML 标签嵌套
- Go 语言标准库为何不提供泛型 Contains
- c# 服务器GC和工作站GC的区别和设置
- Mac如何解压zip和rar文件?(推荐免费工具)
- Win11怎么关闭粘滞键_彻底禁用Windows
- Windows10电脑怎么连接蓝牙设备_Win10
- Win11任务栏天气怎么关闭 Win11隐藏天气小
- VSC怎么创建PHP项目_从零开始搭建项目的步骤【
- Windows10蓝屏SYSTEM_SERVICE
- MAC的“接续互通”功能无法使用怎么办_MAC检查
- Python数据抓取合法性_合规说明【指导】
- Windows系统文件被保护机制阻止怎么办_权限不
- Win11怎么清理C盘虚拟内存_Win11清理虚拟
- c++怎么处理多线程死锁_c++ lock_gua
- Win11怎么开启剪贴板历史记录_Windows1
- c++ nullptr与NULL区别_c++11空
- Win11怎么关闭右下角弹窗_Win11拦截系统通
- 如何使用Golang实现负载均衡_分发请求到多个服
- Windows10系统怎么查看运行时间_Win10
- Python函数缓存机制_lru_cache解析【
- Win11怎么快速锁屏_Win11一键锁屏快捷键W
- Go 语言标准库为何不提供泛型 Contains
- 如何用正则表达式精确匹配最多含一个换行符的起止片段
- Win10系统怎么查看端口状态_Windows10
- Win11怎么关闭系统推荐内容_Windows11


QQ客服