Java 之 CAS(CompareAndSwap)底层原理详解

2024-01-08 09:36

本文主要是介绍Java 之 CAS(CompareAndSwap)底层原理详解,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

目录

一. 前言

二. CAS 底层原理

2.1. 代码实例

2.2. 源码分析

2.3. 底层汇编

2.4. ABA 问题

三. 总结

3.1. CAS 缺点

3.2. CAS 会导致 ABA 问题


 

一. 前言

    CAS 的全称是 Compare-And-Swap,它是 CPU 并发原语。它的功能是判断内存某个位置的值是否为预期值。如果是则更改为新的值,这个过程是原子的。 CAS 并发原语体现在 Java 语言中就是 sun.misc.Unsafe 类的各个方法。调用 UnSafe 类中的 CAS 方法,JVM 会帮我们实现出 CAS汇编指令,这是一种完全依赖于硬件的功能,通过它实现了原子操作,再次强调,由于 CAS 是一种系统原语,原语属于操作系统作用范畴,是由若干条指令组成,用于完成某个功能的一个过程,并且原语的执行必须是连续的,在执行过程中不允许被中断,也就是说 CAS 是一条 CPU 的原子指令,不会造成所谓的数据不一致的问题,也就是说 CAS 是线程安全的。

二. CAS 底层原理

2.1. 代码实例

首先使用 AtomicInteger 创建了一个实例,并初始化为 5:

// 创建一个原子类
AtomicInteger atomicInteger = new AtomicInteger(5);

然后调用 CAS 方法,企图更新成 2024,这里有两个参数,一个是 5,表示期望值,第二个就是我们要更新的值:

atomicInteger.compareAndSet(5, 2024);

然后再次使用了一个方法,同样将值改为 1024:

atomicInteger.compareAndSet(5, 1024);

完整代码如下:

public class CASDemo {public static void main(String[] args) {// 创建一个原子类AtomicInteger atomicInteger = new AtomicInteger(5);/*** 一个是期望值,一个是更新值,但期望值和原来的值相同时,才能够更改* 假设三秒前,我拿的是5,也就是expect为5,然后我需要更新成 2024*/System.out.println(atomicInteger.compareAndSet(5, 2024) + "\t current data: " + atomicInteger.get());System.out.println(atomicInteger.compareAndSet(5, 1024) + "\t current data: " + atomicInteger.get());}
}

上面代码的执行结果为:

true     current date: 2024
false    current date: 2024

这是因为我们执行第一个的时候,期望值和原本值是满足的,因此修改成功,但是第二次后,主内存的值已经改成了 2024,不满足期望值,因此返回了 false,本次写入失败。

03ca51ab2171461199e5e50e34cae9b5.png

这个就类似于 SVN 或者 Git 的版本号,如果没有人更改过,就能够正常提交,否则需要先将代码pull 下来,合并代码后,然后提交。

2.2. 源码分析

首先我们先看看 atomicInteger.getAndIncrement() 方法的源码:

bd02318431f445ae95b583f6eca79343.png

从这里能够看到,底层又调用了一个 unsafe 类的 getAndAddInt() 方法。

unsafe 类:

c506671021374a5b8299ac5a0f11d1f6.jpeg

Unsafe 是 CAS 的核心类,由于 Java 方法无法直接访问底层系统,需要通过本地(Native)方法来访问,Unsafe 相当于一个后门,基于该类可以直接操作特定的内存数据,Unsafe 类存在于sun.misc 包中,其内部方法操作可以像 C 指针一样直接操作内存,因为 Java 中的 CAS 操作的执行依赖于 Unsafe 类的方法。

注意:Unsafe 类的所有方法都是 native 修饰的,也就是说 Unsafe 类中的方法都直接调用操作系统底层资源执行相应的任务。

为什么 Atomic 修饰的包装类,能够保证原子性,依靠的就是底层的 Unsafe 类。关于 Atomic 相关的包装类详细介绍可以参见《JUC之Atomic原子类》。

变量 valueOffset:

表示该变量值在内存中的偏移地址,因为 Unsafe 就是根据内存偏移地址获取数据的。

ce64899eb22c4fa39a555beb37f50ec9.png

从这里我们可以看到,通过 valueOffset,直接通过内存地址,获取到值,然后进行加 1 操作。

变量 value 用 volatile 修饰:

保证了多线程之间的内存可见性。

924525f8bfae444c99ecf90874fe9132.png

var5:就是我们从主内存中拷贝到工作内存中的值。

那么操作的时候,需要比较工作内存中的值,和主内存中的值进行比较。

假设执行 compareAndSwapInt 返回 false,那么就一直执行 while 方法,直到期望的值和真实值一样

  • val1:AtomicInteger 对象本身。
  • var2:该对象值得引用地址。
  • var4:需要变动的数量。
  • var5:用 var1 和 var2 找到的内存中的真实值
    • 用该对象当前的值与 var5 比较;
    • 如果相同,更新 var5 + var4 并返回 true;
    • 如果不同,继续取值然后再比较,直到更新完成。

这里没有用 synchronized,而用 CAS,这样提高了并发性,也能够实现一致性,是因为每个线程进来后,进入的 do while 循环,然后不断的获取内存中的值,判断是否为最新,然后在进行更新操作。

假设线程A和线程B同时执行getAndInt操作(分别跑在不同的CPU上):

  1. AtomicInteger 里面的 value 原始值为3,即主内存中 AtomicInteger 的 value 为3,根据 JMM模型,线程 A 和线程 B 各自持有一份价值为3的副本,分别存储在各自的工作内存;
  2. 线程 A 通过 getIntVolatile(var1, var2)  拿到 value 值3,这时线程 A 被挂起(该线程失去 CPU 执行权);
  3. 线程 B 也通过 getIntVolatile(var1, var2) 方法获取到 value 值也是3,此时刚好线程 B 没有被挂起,并执行了 compareAndSwapInt 方法,比较内存的值也是3,成功修改内存值为4,线程 B 打完收工,一切OK;
  4. 这时线程 A 恢复,执行 CAS 方法,比较发现自己手里的数字3和主内存中的数字4不一致,说明该值已经被其它线程抢先一步修改过了,那么 A 线程本次修改失败,只能够重新读取后再来一遍了,也就是在执行 do while;
  5. 线程 A 重新获取 value 值,因为变量 value 被 volatile 修饰,所以其它线程对它的修改,线程 A 总能够看到,线程 A 继续执行 compareAndSwapInt 进行比较替换,直到成功。

Unsafe 类 + CAS 思想: 也就是自旋,自我旋转。

2.3. 底层汇编

Unsafe 类中的 compareAndSwapInt 是一个本地方法,该方法的实现位于 unsafe.cpp 中:

  1. 先想办法拿到变量 value 在内存中的地址;
  2. 通过 Atomic::cmpxchg 实现比较替换,其中参数 X 是即将更新的值,参数 e 是原内存的值。

 4662407db0b34ef3ab2e0b4ec5fe1a6c.jpeg

2.4. ABA 问题

    假设两个线程 T1 和 T2 访问同一个变量 V,当 T1 访问变量 V 时,读取到 V 的值为 A;此时线程 T1 被抢占了,T2 开始执行,T2 先将变量 V 的值从 A 变成 B,然后又将变量 V 的值从 B 变成A;此时 T1 又抢占了主动权,继续执行,它发现 V 的值还是 A,以为没有变化,所以就继续执行了。这个过程中,变量 V 从 A 变为 B,再由 B 变为 A 就形象地称为 ABA 问题。

三. 总结

3.1. CAS 缺点

CAS 不加锁,保证一次性,但是需要多次比较。

1. 循环时间长,开销大(因为执行的是 do while,如果比较不成功一直在循环,最差的情况,就是某个线程一直取到的值和预期值都不一样,这样就会无限循环)。

2. 只能保证一个共享变量的原子操作:

  • 当对一个共享变量执行操作时,我们可以通过循环 CAS 的方式来保证原子操作;
  • 但是对于多个共享变量操作时,循环 CAS 就无法保证操作的原子性,这个时候只能用锁来保证原子性。

3. 引出 ABA 问题

3.2. CAS 会导致 ABA 问题

    CAS 算法实现的一个重要前提是需要取出内存中某个时刻的数据并在当下时刻比较并替换,那么在这个时间差内会导致数据的变化。

    比如说一个线程 one 从内存位置 V 中取出 A,这个时候另一个线程 two 也从内存位置 V 中取出A,并且线程 two 进行了一些操作将值变成了 B,然后线程 two 又将 V 位置的数据变成 A,这时候线程 one 进行 CAS 操作时发现内存中仍然是 A,然后线程 one 操作成功。

    尽管线程 one 的 CAS 操作成功,但是并不代表这个过程就是没有问题的。

 

这篇关于Java 之 CAS(CompareAndSwap)底层原理详解的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/583034

相关文章

使用Java将DOCX文档解析为Markdown文档的代码实现

《使用Java将DOCX文档解析为Markdown文档的代码实现》在现代文档处理中,Markdown(MD)因其简洁的语法和良好的可读性,逐渐成为开发者、技术写作者和内容创作者的首选格式,然而,许多文... 目录引言1. 工具和库介绍2. 安装依赖库3. 使用Apache POI解析DOCX文档4. 将解析

一文详解如何在Python中从字符串中提取部分内容

《一文详解如何在Python中从字符串中提取部分内容》:本文主要介绍如何在Python中从字符串中提取部分内容的相关资料,包括使用正则表达式、Pyparsing库、AST(抽象语法树)、字符串操作... 目录前言解决方案方法一:使用正则表达式方法二:使用 Pyparsing方法三:使用 AST方法四:使用字

Java字符串处理全解析(String、StringBuilder与StringBuffer)

《Java字符串处理全解析(String、StringBuilder与StringBuffer)》:本文主要介绍Java字符串处理全解析(String、StringBuilder与StringBu... 目录Java字符串处理全解析:String、StringBuilder与StringBuffer一、St

springboot整合阿里云百炼DeepSeek实现sse流式打印的操作方法

《springboot整合阿里云百炼DeepSeek实现sse流式打印的操作方法》:本文主要介绍springboot整合阿里云百炼DeepSeek实现sse流式打印,本文给大家介绍的非常详细,对大... 目录1.开通阿里云百炼,获取到key2.新建SpringBoot项目3.工具类4.启动类5.测试类6.测

Python列表去重的4种核心方法与实战指南详解

《Python列表去重的4种核心方法与实战指南详解》在Python开发中,处理列表数据时经常需要去除重复元素,本文将详细介绍4种最实用的列表去重方法,有需要的小伙伴可以根据自己的需要进行选择... 目录方法1:集合(set)去重法(最快速)方法2:顺序遍历法(保持顺序)方法3:副本删除法(原地修改)方法4:

Spring Boot循环依赖原理、解决方案与最佳实践(全解析)

《SpringBoot循环依赖原理、解决方案与最佳实践(全解析)》循环依赖指两个或多个Bean相互直接或间接引用,形成闭环依赖关系,:本文主要介绍SpringBoot循环依赖原理、解决方案与最... 目录一、循环依赖的本质与危害1.1 什么是循环依赖?1.2 核心危害二、Spring的三级缓存机制2.1 三

C#中async await异步关键字用法和异步的底层原理全解析

《C#中asyncawait异步关键字用法和异步的底层原理全解析》:本文主要介绍C#中asyncawait异步关键字用法和异步的底层原理全解析,本文给大家介绍的非常详细,对大家的学习或工作具有一... 目录C#异步编程一、异步编程基础二、异步方法的工作原理三、代码示例四、编译后的底层实现五、总结C#异步编程

在Spring Boot中浅尝内存泄漏的实战记录

《在SpringBoot中浅尝内存泄漏的实战记录》本文给大家分享在SpringBoot中浅尝内存泄漏的实战记录,结合实例代码给大家介绍的非常详细,感兴趣的朋友一起看看吧... 目录使用静态集合持有对象引用,阻止GC回收关键点:可执行代码:验证:1,运行程序(启动时添加JVM参数限制堆大小):2,访问 htt

SpringBoot集成Milvus实现数据增删改查功能

《SpringBoot集成Milvus实现数据增删改查功能》milvus支持的语言比较多,支持python,Java,Go,node等开发语言,本文主要介绍如何使用Java语言,采用springboo... 目录1、Milvus基本概念2、添加maven依赖3、配置yml文件4、创建MilvusClient

浅析Java中如何优雅地处理null值

《浅析Java中如何优雅地处理null值》这篇文章主要为大家详细介绍了如何结合Lambda表达式和Optional,让Java更优雅地处理null值,感兴趣的小伙伴可以跟随小编一起学习一下... 目录场景 1:不为 null 则执行场景 2:不为 null 则返回,为 null 则返回特定值或抛出异常场景