CAS理解和说明

目录

1.CAS是什么?

2.CAS的应用场景

2.1 实现原子类

2.2 实现自旋锁

3.CAS的典型问题:ABA问题 


1.CAS是什么?

CAS:全称compare and swap(比较并交换)

我们假设内存中的原始数据V,旧的预期值A,需要修改的新值B

1.比较A与V是否相等(比较)

2.如果比较相等,将B写入V(交换)

3.返回操作是否成功

 在这里最特别的是,上述这个CAS的过程,并非是通过一段代码实现的,而是通过一条CPU指令完成的,所以CAS操作是原子的,就可以在一定程度上回避线程安全问题,所以我们在解决线程安全问题除了加锁之外,又有了一个新思路。

 但是我们可以通改CAS伪代码来帮助我们理解这个特殊指令:

    boolean CAS(address, expectValue, swapValue) {if (&address == expectedValue){&address = swapValue;return true;}return false;}

2.CAS的应用场景

2.1 实现原子类

Java标准库里面提供的类

AtomicInteger count = new AtomicInteger(0);
count.getAndDecrement();

count.getAndDecrement();相当于i++

伪代码实现

class AtomicInteger {private int value;public int getAndIncrement() {int oldValue = value;while (CAS(value, oldValue, oldValue + 1) != true) {oldValue = value;}return oldValue;}
}

现在假设有两个线程同时调用上面的getAndDecrement(),

1) 两个线程都读取 value 的值到 oldValue . (oldValue 是一个局部变量, 在栈上。   每个线程有自己的栈 )

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

 此时的value值变成1,但是CAS的返回值为true,所以oldValue的值仍然为0。

3) 线程 2 再执行 CAS 操作的时候 发现 oldValue value 不相等 不能进行赋值。 因此需要进入循环。

循环里重新读取 value 的值赋给 oldValue。

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

此时的value值变成2,但是CAS的返回值为true,所以oldValue的值仍然为1.

5) 线程 1 和 线程 2 返回各自的 oldValue 的值即可。通过形如上述代码就可以实现一个原子类 不需要使用重量级锁 ,  就可以高效的完成多线程的自增操作。

2.2 实现自旋锁

实现自旋锁伪代码

public class SpinLock {private Thread owner = null;public void lock() {while (!CAS(this.owner, null, Thread.currentThread())) {}}public void unlock() {this.owner = null;}
}

private Thread owner = null;

这个代码的含义是当前锁是谁加的。

    public void lock() {
        while (!CAS(this.owner, null, Thread.currentThread())) {
        }
    }

检测当前的owner是否为null,如果为空,就将当前线程赋值给owner。如果赋值成功,则加锁完成,循环结束。如果当前锁已经被其他线程占用,CAS操作会失败,因为this.owner不是null。此时返回false,继续循环进行下一次判定。

3.CAS的典型问题:ABA问题 

它的核心思想是检查当前值与预期值是否相等,如果相等则进行交换操作。然而,ABA问题是一个潜在的问题,即在CAS操作过程中,一个变量的值被修改两次后又恢复到了原来的值,导致CAS误判为没有发生变化,这个问题就叫ABA问题。

虽然这个ABA情况,大部分情况下,其实不会对代码/逻辑产生太大影响,但是不排除一些极端情况,也有可能造成影响。举一个极端的例子:

在考虑使用CAS方式扣款的情况下,假设我现在需要取款500元,我的账户余额为1000元。当我按下取款按钮时,机器可能会卡住,如果我不小心多次按下按钮,可能会导致重复扣款的情况发生,如下图

在执行第二次CAS操作时,如果此时有人转账500元进来,账户余额仍然为1000元,CAS操作会继续扣款。

为了解决这个问题,我们可以引入一个版本号或时间戳的概念。每次对变量进行修改时,同时更新版本号或时间戳。在进行CAS操作时,除了比较当前值和预期值之外,还需要比较版本号或时间戳。只有当两者都匹配时,才认为变量没有被中途修改过,可以进行交换操作

例如,假设我们有一个变量value和一个对应的版本号version,初始值为1。当我们想要更新value时,首先获取当前的version,然后执行更新操作,并将version加1。在进行CAS操作时,我们需要同时比较valueversion。只有当valueversion都与预期值匹配时,才执行交换操作。

通过引入版本号或时间戳,我们可以解决ABA问题,确保在并发环境下的正确性。

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

如若内容造成侵权/违法违规/事实不符,请联系一条长河网进行投诉反馈,一经查实,立即删除!

相关文章

Spring6梳理6——依赖注入之Setter注入

以上笔记来源: 尚硅谷Spring零基础入门到进阶,一套搞定spring6全套视频教程(源码级讲解)https://www.bilibili.com/video/BV1kR4y1b7Qc 目录 一、引言 二、Java方法初始化过程 2.1 set方法及构造器方法实现Book对象初始化 三…

QT实战项目之音乐播放器

项目效果演示 myMusicShow 项目概述 在本QT音乐播放器实战项目中,开发环境使用的是QT Creator5.14版本。该项目实现了音乐播放器的基本功能,例如开始播放、停止播放、下一首播放、上一首播放、调节音量、调节倍速、设置音乐播放模式等。同时还具备搜索功…

C语言:常用技巧及误用

一、字符串存储在数组中 int main() {char* arr[7] {"xiaoming","zhangsan","李四"};printf("%s\n", arr[0]);printf("%s\n", arr[2]);return 0; } 二、scanf()函数用法 2.1 scanf()输入字符串 int main() {char arr[10…

jquery下载的例子如何应用到vue中

参考测试圈相亲平台开发流程(4):选个漂亮的首页 (qq.com) 下载的文件夹解压到v_love项目的pubilc下的static文件夹内,这里放的都是我们的静态资源。 打开文件夹内的index.html,我们先确定下它是不是我们要的东西&…

多目标应用:四种多目标优化算法(NSGA2、NSPSO、NSDBO、NSCOA)求解柔性作业车间调度问题(FJSP),MATLAB代码

一、柔性作业车间调度问题 柔性作业车间调度问题(Flexible Job Scheduling Problem, FJSP) 的描述如下:n个工件 { J , J 2 , . . , J n } \{J,J_2,..,J_n\} {J,J2​,..,Jn​}要在 m m m 台机器 { M 1 , M 2 , . . , M m } \{M_1,M_2,..,M_m\} {M1​,M2​,..,Mm​} …

做了SEO为何效果平平无奇?

SEO(Search Engine Optimization)即搜索引擎优化,指在不同的搜索引擎中,按照相应的规则与机制提高网站在特定的搜索引擎中的自然排名。作为对产品和服务进行数字宣传营销的重要手段,SEO已然成为各企业提高网站曝光和流…

Ubuntu 24.04 安装 英特尔工具包 Intel® Toolkits

目录 1.采用用户界面 GUI 安装英特尔基本工具包 Intel oneAPI Base Toolkit 1.1 下载离线英特尔基本工具包 1.2 安装英特尔基本工具包 1.3 英特尔基本工具包 Intel oneAPI Base Toolkit 环境设置 2.安装英特尔高性能计算工具包 Intel HPC Toolkit 2.1 下载离线英特尔高性…

[MOCO v3] An Empirical Study of Training Self-Supervised Vision Transformers

1、目的 探索基于contrastive/Siamese范式(而非masked auto-encoding范式)和ViT结构(而非卷积网络)的自监督学习 2、方法 MoCo v3 ​​​​​​​ 1)random data augmentation 2)query encoder &a…

Java笔试面试题AI答之正则表达式(3)

文章目录 13. 简述Java String支持哪几种使用正则表达式的方法?14. 请列举常见校验数字的表达式 ?15. 请列举常见校验字符的表达式 ?1. 汉字2. 英文和数字3. 特定长度的字符串4. 由26个英文字母组成的字符串5. 由数字和26个英文字母组成的字符…

【电池专题】软包电池封装工序

铝塑膜成型工序冲坑 铝塑膜成型工序,软包电芯可以根据客户的需求设计成不同的尺寸,当外形尺寸设计好后,就需要开具相应的模具,使铝塑膜成型。 成型工序也叫作冲坑,顾名思义,就是用成型模具在加热的情况下,在铝塑膜上冲出一个能够装卷芯的坑,具体的见下图。 …

「Python程序设计」循环控制:for和while循环语句

​我们在实际业务,或者是实际问题,进行数据分析处理的过程中,往往需要对数据集进行处理。 从程序设计的角度来看,一维数组,代表了同一数据类型的相关数据。二维数组,相当于我们excel中的表格,可…

ML17_变分推断Variational Inference

1. KL散度 KL散度(Kullback-Leibler divergence),也称为相对熵(relative entropy),是由Solomon Kullback和Richard Leibler在1951年引入的一种衡量两个概率分布之间差异的方法。KL散度不是一种距离度量&am…

硬件工程师笔试面试知识器件篇——电容

目录 电容 2.1、基础 电容原理图 电容实物图 2.1.1、定义 2.1.2、原理 2.1.3、电容的类型 分类1: 分类2: 2.1.4、电容的应用 2.2、相关问题 2.2.1、电容器的电容值如何测量 2.2.2、不同类型的电容器在实际应用中有那些具体差异 2.2.3、如何选择合适的电容器来满…

模型从 HuggingFace 转存到 ModelScope

由于 HuggingFace 网络访问比较慢,国内通常会使用魔搭下载模型,如果魔搭上还没有,需要从 HuggingFace 准存一下,本文将通过 Colab AliyunPan 的方式下载模型并进行转存。 登录Colab 并运行一下命令 安装依赖包,Hugg…

SpringBoot-读取配置文件方式

目录 前言 一. 使用 ConfigurationProperties 注解读取 二. 使用 Value 注解读取配置文件 三. 使用 Environment 类获取配置属性 前言 Spring Boot提供了多种灵活的方式来读取配置文件,以适应不同的开发和部署需求,SpringBoot启动的时候,…

Datawhale X 李宏毅苹果书 AI夏令营(深度学习进阶)task3

批量归一化 其实归一化简单一点理解就类似于我们学过的数学中的每个数值减去平均值除以标准差。 神经网络中的批量归一化(Batch Normalization,BN)就是其中一个“把山铲平”的想法。不要小看优化这个问题,有时候就算误差表面是凸…

[深度学习][LLM]:浮点数怎么表示,什么是混合精度训练?

混合精度训练 混合精度训练1. 浮点表示法:[IEEE](https://zh.wikipedia.org/wiki/电气电子工程师协会)二进制浮点数算术标准(IEEE 754)1.1 浮点数剖析1.2 举例说明例子 1:例子 2: 1.3 浮点数比较1.4 浮点数的舍入 2. 混合精度训练2.1 为什么需…

【数据结果-二维前缀和】力扣221. 最大正方形

在一个由 ‘0’ 和 ‘1’ 组成的二维矩阵内,找到只包含 ‘1’ 的最大正方形,并返回其面积。 示例 1: 输入:matrix [[“1”,“0”,“1”,“0”,“0”],[“1”,“0”,“1”,“1”,“1”],[“1”,“1”,“1”,“1”,“1”],[“1”…

Java 入门指南:Java 并发编程 —— 并发容器 TransferQueue、LinkedTransferQueue、SynchronousQueue

BlockingQueue BlockingQueue 是Java并发包(java.util.concurrent)中提供的一个阻塞队列接口,它继承自 Queue 接口。 BlockingQueue 中的元素采用 FIFO 的原则,支持多线程环境并发访问,提供了阻塞读取和写入的操作&a…

机器学习的入门笔记(第十六周)

本周观看了B站up主霹雳吧啦Wz的图像处理的课程, 课程链接:霹雳吧啦Wz的个人空间-霹雳吧啦Wz个人主页-哔哩哔哩视频 下面是本周的所看的课程总结。 MobileNet V2的代码实现 1、定义ConvBNReLU类,将卷积操作,批量归一化操作&…