直接用int64做并发计数器必然导致数据竞争,因counter++非原子;sync.Mutex性能损耗大;atomic.AddInt64和LoadInt64是唯一兼顾正确性与性能的方案,但需注意内存对齐和变量作用域。
为什么不能直接用 int64 做并发计数器
在高频监控场景(比如每秒数万次请求的网关),用普通 int64 变量累加请求数、错误数,会立刻出现数据竞争——go run -race 一跑就报一堆 data race。这不是“可能出错”,而是“必然错”,因为 counter++ 实际是读-改-写三步,多个 goroutine 同时执行就会覆盖彼此结果。
有人试过加 sync.Mutex,但锁开销太大:在单核压测中,锁版吞吐常掉 30%~50%,且锁争用越激烈,延迟毛刺越明显。atomic 是唯一能兼顾正确性与性能的方案。
atomic.AddInt64 和 atomic.LoadInt64 是监控核心组合
系统负载指标(如当前活跃连接数、最近 1 秒请求数)本质是“高频写 + 低频读”。写操作必须无锁、原子、不可中断;读操作要能拿到一致快照,不阻塞写入。
推荐组合:
-
atomic.AddInt64(&counter, 1)用于事件发生时递增(如新连接建立、请求进入) -
atomic.LoadInt64(&counter)用于定时采集(如每 200ms 调用一次上报) - 避免用
atomic.SwapInt64或atomic.CompareAndSwapInt64做计数——它们语义不对,且无必要增加复杂度
示例:记录活跃连接数
var activeConns int64
func onConnOpen() {
atomic.AddInt64(&activeConns, 1)
}
func onConnClose() {
atomic.AddInt64(&activeConns, -1)
}
func report() {
n := atomic.LoadInt64(&activeConns)
log.Printf("active connections: %d", n)
}
注意 atomic 不解决“窗口统计”问题
很多监控需求不是“总值”,而是“过去 1 秒内请求数”或“滑动 P95 延迟”。atomic 本身只提供单变量原子操作,无法直接实现时间窗口聚合。
常见误用:
- 用一个
int64计数器 + 每秒重置 → 重置瞬间丢失计数(StoreInt64(&c, 0)和AddInt64竞争) - 试图用
atomic模拟 ring buffer → 指针/索引更新无法原子化,极易出错
正确做法:用 atomic 配合固定大小环形缓冲区(如 10 个 slot,每个 slot 存 100ms 窗口计数),用 atomic.AddUint64 更新当前 slot,用 atomic.LoadUint64 读全部 slot —— slot 切换靠 time.Since() + 取模,不依赖原子操作。
别忽略内存序和对齐要求
atomic 操作默认使用 Acquire/Release 内存序,对监控场景足够安全,但有两个硬约束必须遵守:
- 被操作变量必须是导出的全局变量或堆上分配的变量(不能是栈上局部变量,逃逸分析会报错)
- 变量类型必须严格对齐:
int64必须 8 字节对齐,否则在 ARM64 或某些旧 x86 系统上 panic:"panic: runtime error: invalid memory address or nil pointer dereference" - 结构体里嵌套
int64字段时,需手动填充对齐(如前面加_ [7]byte),或用//go:notinheap+ 显式unsafe.Alignof校验
最稳妥的方式:所有监控计数器统一定义为包级变量,用 var 声明,不嵌套进结构体,除非你明确控制了字段顺序和填充。
高频监控的麻烦点不在 atomic 本身,而在于如何把原子操作嵌进时间敏感、低延迟、多维度的采集流水线里——计数只是起点,后续的采样策略、序列化开销、推送频率,才是真正卡吞吐的地方。











