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使用protobuf-maven-plugin的插件编译proto文件详解

《java使用protobuf-maven-plugin的插件编译proto文件详解》:本文主要介绍java使用protobuf-maven-plugin的插件编译proto文件,具有很好的参考价... 目录protobuf文件作为数据传输和存储的协议主要介绍在Java使用maven编译proto文件的插件

Android ClassLoader加载机制详解

《AndroidClassLoader加载机制详解》Android的ClassLoader负责加载.dex文件,基于双亲委派模型,支持热修复和插件化,需注意类冲突、内存泄漏和兼容性问题,本文给大家介... 目录一、ClassLoader概述1.1 类加载的基本概念1.2 android与Java Class

Java中的数组与集合基本用法详解

《Java中的数组与集合基本用法详解》本文介绍了Java数组和集合框架的基础知识,数组部分涵盖了一维、二维及多维数组的声明、初始化、访问与遍历方法,以及Arrays类的常用操作,对Java数组与集合相... 目录一、Java数组基础1.1 数组结构概述1.2 一维数组1.2.1 声明与初始化1.2.2 访问

Javaee多线程之进程和线程之间的区别和联系(最新整理)

《Javaee多线程之进程和线程之间的区别和联系(最新整理)》进程是资源分配单位,线程是调度执行单位,共享资源更高效,创建线程五种方式:继承Thread、Runnable接口、匿名类、lambda,r... 目录进程和线程进程线程进程和线程的区别创建线程的五种写法继承Thread,重写run实现Runnab

Java 方法重载Overload常见误区及注意事项

《Java方法重载Overload常见误区及注意事项》Java方法重载允许同一类中同名方法通过参数类型、数量、顺序差异实现功能扩展,提升代码灵活性,核心条件为参数列表不同,不涉及返回类型、访问修饰符... 目录Java 方法重载(Overload)详解一、方法重载的核心条件二、构成方法重载的具体情况三、不构

Java通过驱动包(jar包)连接MySQL数据库的步骤总结及验证方式

《Java通过驱动包(jar包)连接MySQL数据库的步骤总结及验证方式》本文详细介绍如何使用Java通过JDBC连接MySQL数据库,包括下载驱动、配置Eclipse环境、检测数据库连接等关键步骤,... 目录一、下载驱动包二、放jar包三、检测数据库连接JavaJava 如何使用 JDBC 连接 mys

SpringBoot线程池配置使用示例详解

《SpringBoot线程池配置使用示例详解》SpringBoot集成@Async注解,支持线程池参数配置(核心数、队列容量、拒绝策略等)及生命周期管理,结合监控与任务装饰器,提升异步处理效率与系统... 目录一、核心特性二、添加依赖三、参数详解四、配置线程池五、应用实践代码说明拒绝策略(Rejected

一文详解SpringBoot中控制器的动态注册与卸载

《一文详解SpringBoot中控制器的动态注册与卸载》在项目开发中,通过动态注册和卸载控制器功能,可以根据业务场景和项目需要实现功能的动态增加、删除,提高系统的灵活性和可扩展性,下面我们就来看看Sp... 目录项目结构1. 创建 Spring Boot 启动类2. 创建一个测试控制器3. 创建动态控制器注

Java操作Word文档的全面指南

《Java操作Word文档的全面指南》在Java开发中,操作Word文档是常见的业务需求,广泛应用于合同生成、报表输出、通知发布、法律文书生成、病历模板填写等场景,本文将全面介绍Java操作Word文... 目录简介段落页头与页脚页码表格图片批注文本框目录图表简介Word编程最重要的类是org.apach

C#读写文本文件的多种方式详解

《C#读写文本文件的多种方式详解》这篇文章主要为大家详细介绍了C#中各种常用的文件读写方式,包括文本文件,二进制文件、CSV文件、JSON文件等,有需要的小伙伴可以参考一下... 目录一、文本文件读写1. 使用 File 类的静态方法2. 使用 StreamReader 和 StreamWriter二、二进