17370845950

Go中atomic包通过CPU原子指令实现无锁计数，适用于高并发低竞争的简单数值操作；仅支持基础类型原子操作，不提供复合事务语义，需谨慎评估适用场景。

在 Go 中用 atomic 包实现无锁计数，核心是避免互斥锁（sync.Mutex）带来的阻塞和调度开销，适用于高并发、低竞争、只做简单数值操作的场景（如请求计数、指标统计）。关键不是“完全不用锁”，而是用 CPU 级原子指令替代 OS 级锁，由硬件保证操作的不可分割性。

理解 atomic 的适用边界

Go 的 sync/atomic 仅支持基础类型（int32、int64、uint32、uint64、uintptr、*unsafe.Pointer）的原子读写与运算。它不提供复合操作（比如“读-改-写”条件更新需靠 CompareAndSwap 系列手动实现），也不保证内存顺序以外的同步语义。因此：

• 适合：累加器、开关标志、引用计数、简单状态标记
• 不适合：需要事务性更新多个字段、实现队列/栈、或依赖复杂业务逻辑的计数（如“仅当值
• 注意：int64 在 32 位系统上不是原子的，必须用 atomic.LoadInt64 等函数访问，不能直接读写变量

基础计数器：用 AddInt64 和 LoadInt64

最常用模式是声明一个 int64 变量，所有更新走 atomic.AddInt64，读取走 atomic.LoadInt64。Go 编译器会确保生成对应平台的原子指令（如 x86 的 LOCK XADD）。

示例：

var counter int64

// 并发安全地 +1
atomic.AddInt64(&counter, 1)

// 安全读取当前值
n := atomic.LoadInt64(&counter)

无需初始化（零值即 0），也无需额外同步。这是高性能计数的默认起点。

带条件的计数：用 CompareAndSwap 实现“CAS 循环”

当计数逻辑含条件（如“只在小于阈值时递增”），需手动实现 CAS 循环。本质是“读当前值 → 判断是否满足条件 → 计算新值 → 原子尝试更新 → 失败则重试”。

示例：实现一个最大值为 100 的计数器

func incIfLessThan100() {
    for {
        old := atomic.LoadInt64(&counter)
        if old >= 100 {
            return
        }
        if atomic.CompareAndSwapInt64(&counter, old, old+1) {
            return
        }
        // CAS 失败，说明其他 goroutine 已修改，重试
    }
}

这种写法在低竞争下效率高；若竞争激烈，可能反复重试，此时应评估是否真需要无锁，或改用 sync.Mutex 加简单逻辑更稳妥。

内存序与可见性：默认使用 SeqCst，通常够用

Go 的 atomic 函数默认使用 sequential consistency（顺序一致性）模型，意味着所有 goroutine 看到的原子操作执行顺序是一致的，且能自然建立 happens-before 关系。对绝大多数计数场景，无需显式指定内存序（如 atomic.LoadInt64Relaxed）。

只有在极端性能敏感且明确理解弱序语义时，才考虑用 Relaxed / Acquire / Release 变体——但计数器本身极少需要它们。盲目优化反而易出错。

不复杂但容易忽略。