如何在Golang中使用sync/atomic进行原子操作_Golang atomic原子操作实践

新闻中心 NEWS CENTER

您当前位置：首页 > 新闻中心 > 网络学院

如何在Golang中使用sync/atomic进行原子操作_Golang atomic原子操作实践

2025-12-02

浏览次数：次

返回列表

Go语言中sync/atomic包提供原子操作支持，适用于多协程环境下无锁安全读写；2. 原子操作保证变量访问不可中断，避免数据不一致，相比互斥锁更轻量高效；3. 支持int32、int64等基本类型，不直接支持float；4. 常用函数包括LoadXXX、StoreXXX、AddXXX、SwapXXX和CompareAndSwapXXX；5. 适用于计数器、状态标志等简单共享变量场景。

如何在golang中使用sync/atomic进行原子操作_golang atomic原子操作实践

在Go语言中，sync/atomic 包提供了对基本数据类型的原子操作支持，适用于多协程环境下无需锁机制的安全读写。合理使用 atomic 可以提升性能并避免竞态条件，尤其适合计数器、状态标志等简单共享变量的场景。

理解原子操作的核心价值

原子操作保证了对变量的读取、修改和写入过程不可中断，防止多个goroutine同时访问造成数据不一致。相比互斥锁（mutex），atomic 操作更轻量，执行更快，但仅适用于少数特定类型和简单操作。

atomic 支持的数据类型包括：int32、int64、uint32、uint64、uintptr、unsafe.Pointer 和 bool。注意：float 类型没有直接支持，需通过特殊方式处理。

常用原子操作函数实践

以下是 atomic 提供的主要操作函数及其典型用法：

atomic.LoadXXX(&val)：安全读取值
atomic.StoreXXX(&val, newVal)：安全写入值
atomic.AddXXX(&val, delta)：增加值并返回新值
atomic.SwapXXX(&val, newVal)：交换值并返回旧值
atomic.CompareAndSwapXXX(&val, old, new)：比较并交换，成功返回 true

示例：实现一个线程安全的计数器

package main

import (
    "fmt"
    "sync"
    "sync/atomic"
)

func main() {
    var counter int64

    var wg sync.WaitGroup
    for i := 0; i < 1000; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            atomic.AddInt64(&counter, 1)
        }()
    }

    wg.Wait()
    fmt.Println("Counter:", atomic.LoadInt64(&counter)) // 输出: Counter: 1000
}

使用指针进行状态控制

atomic 还可用于管理程序运行状态，比如服务是否已启动或关闭。

Machine Translation

聚合多个来源的AI翻译

49 查看详情 Machine Translation

定义状态常量：

const (
    statusRunning = iota
    statusStopped
)

var status int32 = statusStopped

通过 CompareAndSwap 防止重复启动：

func startService() bool {
    if atomic.CompareAndSwapInt32(&status, statusStopped, statusRunning) {
        fmt.Println("Service started.")
        return true
    }
    fmt.Println("Service already running.")
    return false
}

调用多次只会成功一次，确保初始化逻辑的幂等性。