【JavaEE多线程】深入理解CAS操作:无锁编程的核心

2024-04-18 11:36

本文主要是介绍【JavaEE多线程】深入理解CAS操作:无锁编程的核心,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

目录

    • CAS
      • 什么是CAS
      • CAS是怎么实现的
      • CAS有哪些应用
        • 实现原子类
        • 实现自旋锁
      • CAS的ABA问题


CAS

什么是CAS

CAS:全称Compare and swap,字面意思:”比较并交换“,能够比较和交换某个寄存器中的值内存中的值是否相等,如果相等,则把另一个寄存器中的值和内存进行交换。一个 CAS 涉及到以下操作:

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

  1. 比较 A 与 V 是否相等。(比较)
  2. 如果比较相等,将 B 写入 V。(交换)
  3. 返回操作是否成功。

CAS伪代码

下面写的代码不是原子的, 真实的 CAS 是一个原子的硬件指令完成的. 这个伪代码只是辅助理解CAS 的工作流程.

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

由于CAS是通过一条指令完成的,这也就给我们实现线程安全除了加锁以外又多了一条方式——无锁编程。但CAS的使用范围是有局限性的,加锁适用性更广

CAS是怎么实现的

主要是通过CPU硬件支持,软件层面才做得到

CAS有哪些应用

实现原子类

比如,多线程针对一个count变量进行++,在Java标准库中已经提供了一组原子类

标准库中提供了 java.util.concurrent.atomic 包, 里面的类都是基于这种方式来实现的。其中的AtomicIntegerAtomicLong最常用,提供了自增/自减/自增任意值/自减任意值的操作。这些操作就是基于CAS按照无锁编程的方式来实现

private static AtomicInteger count = new AtomicInteger(0);
public static void main(String[] args) throws InterruptedException {Thread t1 = new Thread(() -> {for (int i = 0; i < 50000; i++) {count.getAndIncrement();//count++/*count.incrementAndGet();//++countcount.getAndDecrement();//count--count.decrementAndGet();//--count*/}});Thread t2 = new Thread(() -> {for (int i = 0; i < 50000; i++) {count.getAndIncrement();}});t1.start();t2.start();t1.join();t2.join();System.out.println(count.get());//获取count的值
}
//100000

上述的原子类,没有进行任何的加锁,就是基于CAS来实现的

伪代码实现:

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

①这里最开始value=0。此时赋值oldValue=value,oldValue为0。

②在循环里的CAS含义是value和oldValue比较是否相等,相等则将value=oldValue+1,返回的是false,不进入循环,最终返回oldValue即0,value是1,这就是相当于i++的效果。

③假设此时有别的线程在①的步骤后穿插进来,则会出现完整的自增流程,此时value=1,oldValue=0,因为还没有进行第二步

④此时重新回到②中,此时value!=oldValue,则函数返回false,将进入循环,将oldValue赋值为新的value=1,则oldValue为1,重新CAS函数比较,此时value和oldValue相等,则value=oldValue+1=2,返回true,退出循环,最终返回oldValue即1,value是2,这就是相当于i++的效果

当两个线程并发的执行i++操作的时候,如果不加任何限制,意味着这两个i++可能是串行的,则计算正确,也可能是穿插进行的,就会出现问题

实现线程安全

  1. 加锁保证线程安全:通过锁,强制避免出现穿插
  2. 原子类/CAS保证线程安全:借助CAS来识别当前是否出现“穿插”的情况,如果没穿插,此时直接修改,就是安全的。如果出现穿插了,就重新获取内存中最新的值,再次尝试修改
实现自旋锁
public class SpinLock {private Thread owner = null;public void lock(){// 通过 CAS 看当前锁是否被某个线程持有. // 如果这个锁已经被别的线程持有, 那么就自旋等待. // 如果这个锁没有被别的线程持有, 那么就把 owner 设为当前尝试加锁的线程(Thread.currentThread()). while(!CAS(this.owner, null, Thread.currentThread())){}}public void unlock (){this.owner = null;}
}

此处owner表示当前是哪个线程持有这把锁。null解锁状态

Thread.currentThread()获取当前线程引用。哪个线程调用lock(),这里得到的结果就是哪个线程的引用

当该锁已经处于加锁状态,这里就会返回false,CAS就不会进行实际的交换操作,接下来循环条件成立,继续进入下一轮循环。但循环体为空,就又进行这个函数判断,因此一瞬间就执行很多轮次,这样就达到了自旋锁效果。一旦有另一个线程把锁释放了,这里就可以立即得到那个锁

CAS的ABA问题

CAS的关键要点是比较寄存器1和内存的值,通过这里的是否相等,来判定内存的值,是否发生了改变。

如果内存值变了,存在其他线程进行了修改;

如果内存值没变,没有别的线程修改,接下来进行的修改就是安全的。

问题是这里的值没变,就一定没有别的线程修改吗?

A-B-A:另一个线程从A->B,又从B->A,此时本线程区分不了,这个值始终没变,还是出现了变化又回来了的情况。

CAS判定的是“值相同”,实际上我们期望的是"值没有变化过"

解决方案:(约定"值"只能增长不能减小,这个值不是要修改的值,是下面引入的“版本号”)

给要修改的值, 引入版本号. 在 CAS 比较数据当前值和旧值的同时, 也要比较版本号是否符合预期.

  • CAS 操作在读取旧值的同时, 也要读取版本号.
  • 真正修改的时候,
    • 如果当前版本号和读到的版本号相同, 则修改数据, 并把版本号 + 1.
    • 如果当前版本号高于读到的版本号. 就操作失败(认为数据已经被修改过了).

CAS 也是属于多线程开发中的一种典型的思路

但是咱们在这里并没有介绍 Java 中提供的 CAS 的api 怎么用,也没介绍系统中提供的 CAS api 咋用

实际开发中,一般不会直接使用 CAS,都是用库里已经基于 CAS 装好的组件(像原子类这种)

后面如果大家被问到了原子类咋实现的,自旋锁咋实现的,就可以用CAS解答了

这篇关于【JavaEE多线程】深入理解CAS操作:无锁编程的核心的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



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

相关文章

Java编译生成多个.class文件的原理和作用

《Java编译生成多个.class文件的原理和作用》作为一名经验丰富的开发者,在Java项目中执行编译后,可能会发现一个.java源文件有时会产生多个.class文件,从技术实现层面详细剖析这一现象... 目录一、内部类机制与.class文件生成成员内部类(常规内部类)局部内部类(方法内部类)匿名内部类二、

SpringBoot实现数据库读写分离的3种方法小结

《SpringBoot实现数据库读写分离的3种方法小结》为了提高系统的读写性能和可用性,读写分离是一种经典的数据库架构模式,在SpringBoot应用中,有多种方式可以实现数据库读写分离,本文将介绍三... 目录一、数据库读写分离概述二、方案一:基于AbstractRoutingDataSource实现动态

揭秘Python Socket网络编程的7种硬核用法

《揭秘PythonSocket网络编程的7种硬核用法》Socket不仅能做聊天室,还能干一大堆硬核操作,这篇文章就带大家看看Python网络编程的7种超实用玩法,感兴趣的小伙伴可以跟随小编一起... 目录1.端口扫描器:探测开放端口2.简易 HTTP 服务器:10 秒搭个网页3.局域网游戏:多人联机对战4.

Springboot @Autowired和@Resource的区别解析

《Springboot@Autowired和@Resource的区别解析》@Resource是JDK提供的注解,只是Spring在实现上提供了这个注解的功能支持,本文给大家介绍Springboot@... 目录【一】定义【1】@Autowired【2】@Resource【二】区别【1】包含的属性不同【2】@

springboot循环依赖问题案例代码及解决办法

《springboot循环依赖问题案例代码及解决办法》在SpringBoot中,如果两个或多个Bean之间存在循环依赖(即BeanA依赖BeanB,而BeanB又依赖BeanA),会导致Spring的... 目录1. 什么是循环依赖?2. 循环依赖的场景案例3. 解决循环依赖的常见方法方法 1:使用 @La

Java枚举类实现Key-Value映射的多种实现方式

《Java枚举类实现Key-Value映射的多种实现方式》在Java开发中,枚举(Enum)是一种特殊的类,本文将详细介绍Java枚举类实现key-value映射的多种方式,有需要的小伙伴可以根据需要... 目录前言一、基础实现方式1.1 为枚举添加属性和构造方法二、http://www.cppcns.co

Elasticsearch 在 Java 中的使用教程

《Elasticsearch在Java中的使用教程》Elasticsearch是一个分布式搜索和分析引擎,基于ApacheLucene构建,能够实现实时数据的存储、搜索、和分析,它广泛应用于全文... 目录1. Elasticsearch 简介2. 环境准备2.1 安装 Elasticsearch2.2 J

Java中的String.valueOf()和toString()方法区别小结

《Java中的String.valueOf()和toString()方法区别小结》字符串操作是开发者日常编程任务中不可或缺的一部分,转换为字符串是一种常见需求,其中最常见的就是String.value... 目录String.valueOf()方法方法定义方法实现使用示例使用场景toString()方法方法

Java中List的contains()方法的使用小结

《Java中List的contains()方法的使用小结》List的contains()方法用于检查列表中是否包含指定的元素,借助equals()方法进行判断,下面就来介绍Java中List的c... 目录详细展开1. 方法签名2. 工作原理3. 使用示例4. 注意事项总结结论:List 的 contain

Java实现文件图片的预览和下载功能

《Java实现文件图片的预览和下载功能》这篇文章主要为大家详细介绍了如何使用Java实现文件图片的预览和下载功能,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... Java实现文件(图片)的预览和下载 @ApiOperation("访问文件") @GetMapping("