详解CAS及ABA问题

🌈🌈🌈今天给大家分享的是 CAS 问题。

清风的CSDN博客

🛩️🛩️🛩️希望我的文章能对你有所帮助,有不足的地方还请各位看官多多指教,大家一起学习交流!

✈️✈️✈️动动你们发财的小手,点点关注点点赞!在此谢过啦!哈哈哈!😛😛😛

目录

一、什么是CAS 

1.1 CAS 伪代码  

1.2 CAS是怎么实现的 

二、CAS有哪些应用 

2.1 实现原子类

2.2 实现自旋锁 

三、CAS 的 ABA 问题

3.1 什么是ABA问题

3.2 ABA问题引来的BUG 

3.3 ABA问题的解决方案


一、什么是CAS 

CAS: 全称 Compare and swap ,字面意思 :” 比较并交换 ,一个 CAS 涉及到以下操作:
我们假设内存中的原数据V,旧的预期值A,需要修改的新值B。
  • 比较 A 与 V 是否相等。(比较)
  • 如果比较相等,将 B 写入 V。(交换)
  • 返回操作是否成功。

1.1 CAS 伪代码  

下面写的代码不是原子的, 真实的 CAS 是一个原子的硬件指令完成的。这个伪代码只是辅助理解CAS 的工作流程。
boolean CAS(address, expectValue, swapValue) {if (&address == expectedValue) {&address = swapValue;return true;}return false;
}
当多个线程同时对某个资源进行 CAS 操作,只能有一个线程操作成功,但是并不会阻塞其他线程 , 其他线程只会收到操作失败的信号。
CAS 可以视为是一种乐观锁。(或者可以理解成 CAS 是乐观锁的一种实现方式)

1.2 CAS是怎么实现的 

针对不同的操作系统, JVM 用到了不同的 CAS 实现原理,简单来讲:
  • java CAS 利用的的是 unsafe 这个类提供的 CAS 操作
  • unsafe CAS 依赖了的是 jvm 针对不同的操作系统实现的 Atomic::cmpxchg
  • Atomic::cmpxchg 的实现使用了汇编的 CAS 操作,并使用 cpu 硬件提供的 lock 机制保证其原子性。

简而言之,是因为硬件予以了支持,软件层面才能做到 

二、CAS有哪些应用 

2.1 实现原子类

标准库中提供了 java.util.concurrent.atomic , 里面的类都是基于这种方式来实现的。 典型的就是 AtomicInteger 类, 其中的 getAndIncrement 相当于 i++ 操作。
AtomicInteger atomicInteger = new AtomicInteger(0);
// 相当于 i++
atomicInteger.getAndIncrement();

伪代码实现:

class AtomicInteger {private int value;public int getAndIncrement() {int oldValue = value;while ( CAS(value, oldValue, oldValue+1) != true) {oldValue = value;}return oldValue;}
}
假设两个线程同时调用 getAndIncrement
① 两个线程都读取 value 的值到 oldValue 中。 (oldValue 是一个局部变量 , 在栈上 . 每个线程有自己的栈 )

② 线程1 先执行 CAS 操作,由于 oldValue value 的值相同, 直接进行对 value 赋值。

注意:
  • CAS 是直接读写内存的, 而不是操作寄存器
  • CAS 的读内存、 比较、 写内存操作是一条硬件指令, 是原子的

③ 线程2 再执行 CAS 操作, 第一次 CAS 的时候发现 oldValue value 不相等, 不能进行赋值,因此需要进入循环,在循环里重新读取 value 的值赋给 oldValue

 ④ 线程2 接下来第二次执行 CAS, 此时 oldValue value 相同, 于是直接执行赋值操作

 ⑤ 线程1 和 线程2 返回各自的 oldValue 的值即可。

通过形如上述代码就可以实现一个原子类, 不需要使用重量级锁 , 就可以高效的完成多线程的自增操作。

2.2 实现自旋锁 

基于 CAS 实现更灵活的锁 , 获取到更多的控制权:
自旋锁伪代码
public class SpinLock {private Thread owner = null;public void lock(){// 通过 CAS 看当前锁是否被某个线程持有. // 如果这个锁已经被别的线程持有, 那么就自旋等待. // 如果这个锁没有被别的线程持有, 那么就把 owner 设为当前尝试加锁的线程. while(!CAS(this.owner, null, Thread.currentThread())){}}public void unlock (){this.owner = null;}
}

三、CAS 的 ABA 问题

3.1 什么是ABA问题

假设存在两个线程 t1 t2,  有一个共享变量 num, 初始值为 A,接下来, 线程 t1 想使用 CAS num 值改成 Z, 那么就需要:
  • 先读取 num 的值, 记录到 oldNum 变量中
  • 使用 CAS 判定当前 num 的值是否为 A, 如果为 A, 就修改成 Z

但是, t1 执行这两个操作之间, t2 线程可能把 num 的值从 A 改成了 B, 又从 B 改成了 A。

线程 t1 的 CAS 是期望 num 不变就修改, 但是 num 的值已经被 t2 给改了, 只不过又改成 A 了,这个时候 t1 究竟是否要更新 num 的值为 Z 呢?

到这一步, t1 线程无法区分当前这个变量始终是 A, 还是经历了一个变化过程:

这就好比, 我们买一个手机, 无法判定这个手机是刚出厂的新手机, 还是别人用旧了, 又翻新过的手机。

3.2 ABA问题引来的BUG 

大部分的情况下 , t2 线程这样的一个反复横跳改动 , 对于 t1 是否修改 num 是没有影响的, 但是不排除一些特殊情况。
假设滑稽老哥有 100 存款, 滑稽想从 ATM 取 50 块钱。取款机创建了两个线程, 并发的来执行 -50 操作,我们期望一个线程执行 -50 成功, 另一个线程 -50 失败。
正常的过程
  • 存款 100,线程1 获取到当前存款值为 100, 期望更新为 50; 线程2 获取到当前存款值为 100, 期望更新为 50。
  • 线程1 执行扣款成功, 存款被改成 50,线程2 阻塞等待中。
  • 轮到线程2 执行了, 发现当前存款为 50, 和之前读到的 100 不相同, 执行失败。
异常的过程
  • 存款 100. 线程1 获取到当前存款值为 100, 期望更新为 50; 线程2 获取到当前存款值为 100, 期望更新为 50
  • 线程1 执行扣款成功, 存款被改成 50,线程2 阻塞等待中
  • 在线程2 执行之前, 滑稽的朋友正好给滑稽转账 50, 账户余额变成 100 
  • 轮到线程2 执行了, 发现当前存款为 100, 和之前读到的 100 相同, 再次执行扣款操作

 这个时候, 扣款操作被执行了两次!!! 都是 ABA 问题搞的鬼!!

3.3 ABA问题的解决方案

给要修改的值 , 引入版本号,   CAS 比较数据当前值和旧值的同时 , 也要比较版本号是否符合预期
  • CAS 操作在读取旧值的同时, 也要读取版本号
  • 真正修改的时候, 如果当前版本号和读到的版本号相同, 则修改数据, 并把版本号 + 1。
  • 如果当前版本号高于读到的版本号,就操作失败(认为数据已经被修改过了)。
这就好比, 判定这个手机是否是翻新机, 那么就需要收集每个手机的数据, 第一次挂在电商网站上的手机记为版本1, 以后每次这个手机出现在电商网站上, 就把版本号进行递增,这样如果买家不在意这是翻新机, 就买,如果买家在意, 就可以直接略过。

 对比理解上面的转账例子:

假设 滑稽老哥 有 100 存款,滑稽想从 ATM 取 50 块钱,取款机创建了两个线程, 并发的来执行 -50 操作。我们期望一个线程执行 -50 成功, 另一个线程 -50 失败。
为了解决 ABA 问题, 给余额搭配一个版本号, 初始设为 1。
  • 存款 100。 线程1 获取到 存款值为 100, 版本号为 1, 期望更新为 50; 线程2 获取到存款值为 100, 版本号为 1, 期望更新为 50。
  • 线程1 执行扣款成功, 存款被改成 50, 版本号改为2,线程2 阻塞等待中。
  • 在线程2 执行之前, 滑稽的朋友正好给滑稽转账 50, 账户余额变成 100, 版本号变成3。
  • 轮到线程2 执行了, 发现当前存款为 100, 和之前读到的 100 相同, 但是当前版本号为 3, 之前读到的版本号为 1, 版本小于当前版本, 认为操作失败。

🌈🌈🌈好啦,今天的分享就到这里!

🛩️🛩️🛩️希望各位看官读完文章后,能够有所提升。

🎉🎉🎉创作不易,还希望各位大佬支持一下!

✈️✈️✈️点赞,你的认可是我创作的动力!

⭐⭐⭐收藏,你的青睐是我努力的方向!

✏️✏️✏️评论:你的意见是我进步的财富!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/610407.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Hex2Bin转换软件、Bootloader 、OTA加密升级 、STM32程序加密、其他MCU同样适用

说明:这个工具可以将 Hex 文件 转换为 Bin 格式文件,软件是按自己开发 STM32 OAT 功能需求开发的一款辅助 上位机软件。 文中的介绍时 bootloader boot 文档在补充完善中... 有兴趣的朋友可留言探讨。 1. 软件功能: 1.生成 bin&#x…

基于模块自定义扩展字段的后端逻辑实现(二)

目录 一:创建表 二:代码逻辑 上一节我们详细讲解了自定义扩展字段的逻辑实现和表的设计,这一节我们以一个具体例子演示下,如何实现一个订单模块的自定义扩展数据。 一:创建表 订单主表: CREATE TABLE t_order ( …

VSCode C/C++(gdb)调试指南

1、安装插件 2、F5开启调试 左侧侧边栏->确保打开回调栈 右键函数栈->查看反汇编 3、打印寄存器、函数反汇编等 命令: 查看main反汇编 -exec disassemble /m main 查看寄存器 -exec info r 打印某个变量 -exec print s 或者 --s 打印寄存器,如p…

如何在没有密码的情况下将 iPhone 13/14/15 恢复出厂设置

您想知道如何在没有密码的情况下将 iPhone 13/14/15 恢复出厂设置吗? 出厂重置 iPhone 13/14/15 成为所有 iPhone 机型中最简单的。大多数情况下,iPhone 13/14/15 是在 iOS 15 或更高版本的 iOS 版本上,Apple 更新了无需密码重置 iPhone 13/…

nodejs 服务端token 高效缓存验证

在前后端分离开发过程中,经常涉及权限验证的问题,一般都是采用由服务端根据前端传递的用户名和密码,验证成功后生成token,然后前端在访问服务端接口时,再附带token访问。 如果服务端高频次的解析token,进行内容验证,则会大大降低接口性能,而采用内存或者redis进行合法…

IoT 物联网 MQTT 协议 5.0 版本新特性

MQTT 是一种基于发布/订阅模式的轻量级消息传输协议,专门为设备资源有限和低带宽、高延迟的不稳定网络环境的物联网场景应用而设计,可以用极少的代码为联网设备提供实时可靠的消息服务。MQTT 协议广泛应用于智能硬件、智慧城市、智慧农业、智慧医疗、新零…

GAMES101-Assignment5

一、问题总览 在这次作业中,要实现两个部分:光线的生成和光线与三角的相交。本次代码框架的工作流程为: 从main 函数开始。我们定义场景的参数,添加物体(球体或三角形)到场景中,并设置其材质&…

项目管理:风险的来源及管理方法

项目风险是项目管理中的难点之一,虽然我们无法将其完全消除,但可以提前做好准备,将风险降至最低。 项目风险如同暗礁潜伏,你和团队需时刻保持警惕。以下几种风险需特别关注: 措施不足:成本与行动的误差&…

Python 基础(三):字符串

目录 简介2 基本操作2.1 访问2.2 单个字符编码 3 转义符4 运算符5 格式化 简介 之前我们已经提到了:字符串是 Python 的一种数据类型,它可以通过单引号 ‘、双引号 "、三引号 ‘’’ 或 “”" 来定义,本节我们来详细介绍一下。 2…

加速科技ST2500 数模混合信号测试设备累计装机量突破500台!

国产数字机,测试中国芯!新年伊始,国产半导体测试设备领军企业加速科技迎来了振奋人心的一刻,ST2500 数模混合信号测试设备累计装机量突破500台!加速科技凭借其持续的创新能力、完善的解决方案能力、专业热忱的本地化服…

软件定义存储

软件定义存储源于VMware公司于2012年提出的软件定义的数据中心(SDDC)。存储作为软件定义的数据中心不可或缺的一部分,其以虚拟化为基础,但又不仅限于虚拟化。存储虚拟化一般只能在专门的硬件设备上应用,很多设备都是经…

笔记本摄像头模拟监控推送RTSP流

使用笔记本摄像头模拟监控推送RTSP流 一、基础安装软件准备 本文使用软件下载链接:下载地址 FFmpeg软件: Download ffmpeg 选择Windows builds by BtbN 一个完整的跨平台解决方案,用于录制、转换和流式传输音频和视频。 EasyDarwin软件:Download Easy…

实习周志实习生实习报告总结定

第一周: 这是我作为前端实习生的第一周,充满了新奇和挑战。在这周里,我主要熟悉了公司的前端开发环境和项目代码结构。我参与了小组的日常会议,了解了当前项目的进展和团队成员的分工。 遇到的问题: 在初始的学习阶…

企业小文件多传输慢怎么办?怎么解决海量小文件传输慢的问题?

在当今信息时代,许多企业在文件传输过程中普遍面临一个棘手问题——小文件传输缓慢。这不仅对企业工作效率产生不良影响,还可能导致运营成本增加以及数据遗失与损坏的风险。那么,企业应该如何解决海量小文件传输缓慢的问题呢?本文…

高压MOS在适配器产品上的应用-REASUNOS瑞森半导体

一、适配器定义 电源适配器,英文Adapter通常指AC-DC(由交流输入转换为直流输出)的开关电源;一般由控制 IC、MOS管、整流肖特基管、电阻电容、磁性材料、DC 线、外壳等元器件及部件组成,通过整流、变压和稳压等转换形式…

2024系统分析师---论设计模式及其应用

摘要: 本人于2018年1月参与了中石化XX油田XX采油厂“用电管理系统”的项目建设,该系统建设目标是实现分单位、分线路、分系统评价、优化、考核,全面提升采油厂用电管理水平。在该项目组中我担任系统架构师一职,主要负责系统整体架…

第1章 引言

目录 1. 鸢尾花分类1.1 初识数据1.2 衡量模型是否成功:训练数据与测试数据1.3 要事第一:观察数据1.4 构建第一个模型:k近邻算法(KNeighborsClassifier)1.5 做出预测(predict)1.6 评估模型 1. 鸢…

【51单片机】延时函数delay的坑——关于无符号整型数据for语句“x >= 0“变成死循环

请认真看看以下延时函数是否正确,并且指出错误:(考考C语言功底) void delay_ms(unsigned int xms) //delay x ms {unsigned int x,y;for(xxms;x>0;x--)for(y124;y>0;y--); }废话少说,上正确代码: v…

C++ 数据结构

C/C 数组允许定义可存储相同类型数据项的变量,但是结构是 C 中另一种用户自定义的可用的数据类型,它允许您存储不同类型的数据项。 结构用于表示一条记录,假设您想要跟踪图书馆中书本的动态,您可能需要跟踪每本书的下列属性&…

青少年软件编程(C/C++)等级考试试卷(二级)2023年12月

202312 青少年软件编程(C/C)等级考试试卷(二级)电子学会真题 编程题 1.统计指定范围里的数 给定一个数的序列S,以及一个区间[L, R], 求序列中介于该区间的数的个数,即序列中大于等于L且小于等于R的数的个…