当前位置: 首页 > backend >正文

Go同步原语与数据竞争:原子操作(atomic)

在Go并发编程中,当多个 goroutine 同时读写共享变量时,如果没有妥善同步,就会出现数据竞争(Data Race)。Go 提供了 sync/atomic 包,用于实现轻量级的原子操作,避免使用锁所带来的性能开销。


一、什么是原子操作?

原子操作指的是在执行过程中不会被任何其他操作中断的操作。在多线程环境中,原子操作确保某个变量的读、写、加减等操作具有一致性和安全性。


二、常用原子操作函数

Go 的 sync/atomic 包支持以下常用操作,主要用于 int32int64uint32uint64 和 unsafe.Pointer 等类型:

函数说明
atomic.LoadInt32(&val)原子读取值
atomic.StoreInt32(&val, new)原子写入值
atomic.AddInt32(&val, delta)原子加法(并返回新值)
atomic.CompareAndSwapInt32(&val, old, new)原子比较并交换
同理还有 Int64Uint32Uint64Pointer 版本

三、使用示例

示例:并发计数器
package mainimport ("fmt""sync""sync/atomic"
)func main() {var counter int32 = 0var wg sync.WaitGroupfor i := 0; i < 1000; i++ {wg.Add(1)go func() {defer wg.Done()atomic.AddInt32(&counter, 1)}()}wg.Wait()fmt.Println("Final Counter:", counter) // 输出应该为 1000
}

这个例子中我们使用 atomic.AddInt32 来确保并发写入是安全的,避免了 race condition


四、CompareAndSwap:原子级条件更新

CompareAndSwap 是一个非常强大的函数,可用于实现无锁状态切换。

var status int32 = 0// 尝试将状态从 0 改为 1
if atomic.CompareAndSwapInt32(&status, 0, 1) {fmt.Println("切换状态成功")
} else {fmt.Println("状态已被修改")
}

如果当前值等于期望值,就会被新值替换;否则不做任何操作,适用于状态机、CAS 重试等场景。


五、原子 vs 锁

方面原子操作(atomic)锁(Mutex/RWMutex)
性能极高(CPU级指令)较低(涉及调度、抢占)
适用场景简单计数、状态标记复杂结构同步
编程复杂度较高,易出错较低,语义清晰
死锁风险存在风险

六、使用注意事项

  • • 原子操作仅适用于简单变量的并发读写,如计数器、标志位。
  • • 不能对结构体、map、slice 等复杂类型直接使用。
  • • 原子操作不能和普通操作混用,否则仍可能产生竞态条件。
  • • 如需读写多个变量或复合结构,推荐使用 sync.Mutex

七、小结

  • • sync/atomic 提供了高性能的原子操作,是无锁并发的核心工具。
  • • 适合用于计数器、自旋锁、状态标识等场景。
  • • 不适合管理复杂共享数据,不能代替所有同步手段。

http://www.xdnf.cn/news/14289.html

相关文章:

  • 【LangChain】4 基于文档的问答
  • 【量化】策略交易之动量策略(Momentum)
  • Transformer实战——从词袋模型到Transformer:NLP技术演进
  • Kubernetes镜像拉取认证指南
  • 勇者和魔塔的算法题
  • Linux进程池详解:从入门到理解
  • Vue 3 九宫格抽奖系统,采用优雅的 UI 设计和流畅的动画效果
  • 【工具变量】全国分省数字基础设施水平数据集-含原始数据及处理代码(2005-2024年)
  • LLMs 系列实操科普(6)
  • 网络代理设置
  • leetcode0765. 情侣牵手-hard
  • HTTP和HTTPS协议
  • Design Compiler:解组(Ungroup)
  • Modbus协议全方位解析与C#开发实战指南
  • Apache Doris FE 问题排查与故障分析全景指南
  • TI 毫米波雷达走读系列—— 3DFFT及测角
  • python基础举例
  • 人工智能学习19-Pandas-设置
  • OSI 七层网络模型
  • 分类预测 | Matlab基于AOA-VMD-LSTM故障诊断分类预测
  • WebSocket与XMPP:即时通讯技术的本质区别与选择逻辑优雅草卓伊凡|片翼|许贝贝
  • day31 打卡
  • 语音交互革命:基于 Amazon Nova Sonic + MCP 构建下一代沉浸式 Agent
  • 从 C 语言计算器到串口屏应用
  • Chapter10-XXE
  • PDF转Markdown基准测试
  • Python训练打卡Day50
  • RabbitMQ核心函数的参数意义和使用场景
  • 动态多目标进化算法:基于迁移学习的动态多目标粒子群优化算法(TrMOPSO)求解IEEE CEC 2015,提供完整MATLAB代码
  • 数据库学习笔记(十六)--控住流程与游标