【多线程】CAS的原理及应用，看这篇文章就够啦

💐个人主页：初晴~

📚相关专栏：多线程 / javaEE初阶

一、CAS概述

CAS（Compare and Swap），中文译为 “比较并交换” ，是一种无锁算法中常用的原子操作。CAS通常用于实现线程之间的同步，特别是在多线程环境下需要保证原子性的场景下。

compareAndSwap(V, A, B)

CAS操作涉及三个操作数：内存位置（V）、预期原值（A）和新值（B）。如果内存位置的值与预期原值相匹配，那么处理器会自动将该位置的值更新为新值。否则，操作失败，处理器不做任何事情。

简单来说就是以下三步：

1. ⽐较 A 与 V 是否相等。（⽐较）
2. 如果⽐较相等，将 B 写⼊ V。（交换）
3. 返回操作是否成功。
一般来说，V就是内存中的值，A就是CPU寄存器中的值，如果发现两者相同，就可以粗略认为该值未被其它线程修改，于是就正常进行交换操作（交换的是内存与另一个寄存器的值，目的是让内存中的值得到更新赋值操作）
优点：
  1. 无需锁：CAS操作本身就是一个原子操作，因此可以在不使用锁的情况下实现多线程环境下的同步。
  2. 减少上下文切换：相比于传统的锁机制，使用CAS可以减少线程上下文切换的次数，提高性能。
  3. 易于实现：CAS的实现相对简单，可以方便地在多线程环境中使用。
尽管CAS具有许多优点，但它也存在一些固有的局限性：
  1. 循环时间长的问题：在并发量较大的情况下，CAS操作可能因为一直获取不到正确的预期值而陷入无限循环，导致CPU使用率上升。
  2. 只能保证一个共享变量的原子性：如果需要对多个共享变量进行原子操作，则CAS无法直接实现，需要结合其他手段，如使用AtomicReference或者其他同步机制。
  3. ABA问题：如果一个值在两次比较之间被修改回原来的值，那么CAS操作将会成功，但实际上中间发生过更改。这被称为ABA问题，在后文我们会再进行详细叙述的。

二、CAS的实现

CAS（Compare and Swap）操作是一种硬件级别的原子操作，用于实现无锁编程模式中的原子更新。在Java中，CAS操作主要通过Unsafe类来实现，并被广泛应用于java.util.concurrent包下的原子类中，如AtomicInteger、AtomicLong等。

CAS的硬件支持

CAS操作依赖于现代处理器提供的原子指令，例如Intel x86架构中的CMPXCHG（Compare and Exchange）指令，ARM架构中的LDREX/STREX（Load Exclusive / Store Exclusive）指令等。这些指令能够保证比较和交换操作的原子性，即使在多处理器环境下也不会被中断。

Java中CAS的实现

在Java中，Unsafe类提供了访问底层硬件的能力，包括执行CAS操作。Unsafe类并不是公开的API，它位于sun.misc包中，并且是隐藏的，不允许直接实例化。但是，Java的原子类（如AtomicInteger）通过反射等方式间接使用了Unsafe类来实现CAS操作。

Unsafe类中有几个关键方法用于实现CAS操作：

  1. compareAndSwapInt：用于整型变量的CAS操作。
  2. compareAndSwapLong：用于长整型变量的CAS操作。
  3. compareAndSwapObject：用于引用类型的CAS操作。

这些方法接受的对象参数是目标对象、预期旧值、新值以及一个表示目标字段偏移量的整数。偏移量通常是通过反射获取的。

不过直接使用Unsafe类通常是不推荐的，因为它涉及到底层操作，容易出现安全性问题。通常我们会使用更高层次的API，如AtomicInteger等。

三、CAS简单应用

（1）实现原子类

标准库中提供了 java.util.concurrent.atomic 包, ⾥⾯的类都是基于这种⽅式来实现的.
典型的就是 AtomicInteger 类。以下是其中一些重要的方法：

  1. get()：获取当前的整数值。
  2. set(int newValue)：设置整数值。
  3. getAndIncrement()：返回当前值，然后将值加一，相当于i++。
  4. getAndDecrement()：返回当前值，然后将值减一，相当于i--。
  5. incrementAndGet()：将值加一，然后返回新的值，相当于++i。
  6. decrementAndGet()：将值减一，然后返回新的值，相当于--i。
  7. addAndGet(int delta)：将当前值加上一个增量，然后返回新的值，相当于+=delta。
  8. getAndAdd(int delta)：返回当前值，然后将当前值加上一个增量，相当于-=delta。
  9. compareAndSet(int expect, int update)：如果当前值等于预期值，则原子地将值设置为新值；返回一个布尔值指示是否成功。

让我们看看下面这个伪代码：

接着通过CAS（value，oldValue，oldValue+1）来对比寄存器中的数据与内存数据是否相等来保证执行的准确性：

  • 若相等，就通过将oldValue+1赋值给内存数据oldValue，并返回true退出while循环， 实现安全的修改变量操作
  • 若不相等，则说明在 上方的赋值 与 此处的 CAS 操作之间有其它的线程穿插执行改变了内存数据，这时就返回false给while循环，重新执行“oldVlue = value”，从而重新加载内存中的值到寄存器中

过去的++操作需要三个指令，不具备原子性，就容易出现线程安全问题：

 而通过CAS就能解决这一问题，将原来的add指令改为CAS，在真正执行++操作时会判断寄存器的值与内存中的值是否相等，若相等，则近似等价于数据未发生改变，则正常执行++操作并赋值。若发现值不同，则说明该操作被其他线程给插入了，就会重新从load指令开始重新执行操作，从而避免了线程问题的产生：

这样我们就可以利用原子类 AtomicInteger 来实现一个线程安全的计时器：

public class AtomicIntegerCounterExample {public static void main(String[] args) throws InterruptedException {//创建一个原子类AtomicInteger counter = new AtomicInteger(0);int threadCount = 10;CountDownLatch latch = new CountDownLatch(threadCount);//创建了一个线程池ExecutorService executor = Executors.newFixedThreadPool(threadCount);for (int i = 0; i < threadCount; i++) {executor.execute(() -> {for (int j = 0; j < 1000; j++) {//相当于++操作counter.incrementAndGet();}latch.countDown();});}latch.await(); // 等待所有线程完成executor.shutdown();System.out.println("Final count: " + counter.get());}
}

在上述代码中，我们就创建了一个 AtomicInteger对象counter，并通过一个线程池创建了多个线程来对计数器进行递增操作。每个线程递增计数器1000次，最终打印出计数器的最终值。由于AtomicInteger的原子性，即使在多线程环境下，计数器的值也是准确的。

（2）实现自旋锁

自旋锁是一种同步机制，当一个线程试图获取已经被其他线程持有的锁时，它不会立即放弃CPU，而是继续循环尝试获取锁，直到成功为止。在 常见锁策略 一文中曾介绍过这一机制。

基于CAS实现自旋锁的步骤：

  1. 初始化锁标志：定义一个标志位来表示锁的状态，通常是一个整型变量。
  2. 获取锁：当一个线程想要获取锁时，它会使用CAS操作尝试将锁标志设置为已锁定状态。
  3. 释放锁：当线程完成其临界区操作后，它会将锁标志恢复为未锁定状态，以便其他线程可以获取锁。
  4. 自旋等待：如果CAS操作失败（即锁已被其他线程占用），当前线程将在一个循环中继续尝试获取锁，直到成功为止。
import java.util.concurrent.atomic.AtomicInteger;public class SpinLock {private final AtomicInteger lock = new AtomicInteger(0); // 0 表示未锁定，1 表示已锁定/*** 尝试获取锁。*/public void lock() {while (!lock.compareAndSet(0, 1)) {// CAS操作失败，说明锁已被占用，继续循环尝试}}/*** 释放锁。*/public void unlock() {lock.compareAndSet(1, 0); // 释放锁}public static void main(String[] args) {SpinLock spinLock = new SpinLock();// 模拟两个线程对共享资源的访问Thread t1 = new Thread(() -> {spinLock.lock();try {System.out.println(Thread.currentThread().getName() + " acquired the lock.");Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();} finally {System.out.println(Thread.currentThread().getName() + " released the lock.");spinLock.unlock();}});Thread t2 = new Thread(() -> {spinLock.lock();try {System.out.println(Thread.currentThread().getName() + " acquired the lock.");Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();} finally {System.out.println(Thread.currentThread().getName() + " released the lock.");spinLock.unlock();}});t1.start();t2.start();}
}

在上述代码中，我们定义了一个SpinLock类，它使用AtomicInteger来实现自旋锁的逻辑。lock()方法使用CAS操作尝试获取锁，如果获取失败，则进入自旋等待。unlock()方法则用于释放锁。

注意：

  1. 自旋次数：在高并发环境下，自旋锁可能会导致CPU利用率较高。可以考虑在自旋一定次数后让线程挂起，然后再尝试获取锁。
  2. 公平性：默认情况下，上述实现的自旋锁是非公平的，即先等待的线程不一定能先获取锁。如果需要公平性，可以考虑实现一个公平的自旋锁。
  3. 性能考量：自旋锁适合于锁的持有时间较短的情况。如果锁的持有时间较长，应该考虑使用传统的阻塞锁机制。

通过这种方式实现的自旋锁可以在一定程度上提高并发性能，特别是在锁的持有时间较短的情况下。然而，对于长时间持有的锁，还是建议使用传统的锁机制来避免不必要的CPU开销。

四、ABA问题

概述

假设有一个变量V，它的初始值为A。现在有以下过程：

  1. 线程T1读取V的值为A。
  2. 线程T2修改V的值为B。
  3. 线程T2再次修改V的值为A。
  4. 线程T1尝试使用CAS操作将V的值从A修改为C。

在这个过程中，尽管线程T1的CAS操作成功了（因为V的当前值确实为A），但实际上V曾经被修改过，这可能会导致不正确的结果。这就是所谓的ABA问题。

这时候有人可能就会有疑问了，就从结果上来看对于t1线程的执行似乎也没啥问题呀？的确在大多数应用场景下ABA问题并不会带来bug，但在下面这个场景中就不一定了：

比如通过CAS方法来实现ATM的转账功能。

        jay有100的存款，想从 ATM 取 50 块钱. 取款机创建了两个线程, 并发的来执⾏ -50 操作。我们期望⼀个线程执⾏ -50 成功, 另⼀个线程 -50 失败。如果使⽤ CAS 的⽅式来完成这个扣款过程就可能出现问题

正常的过程
1. 存款 100. 线程1 获取到当前存款值为 100, 期望更新为 50; 线程2 获取到当前存款值为 100, 期望更新为 50.
2. 线程1 执⾏扣款成功, 存款被改成 50. 线程2 阻塞等待中.
3. 轮到线程2 执⾏了, 发现当前存款为 50, 和之前读到的 100 不相同, 执⾏失败.
异常的过程
1. 存款 100. 线程1 获取到当前存款值为 100, 期望更新为 50; 线程2 获取到当前存款值为 100, 期望更新为 50.
2. 线程1 执⾏扣款成功, 存款被改成 50. 线程2 阻塞等待中.
3. 在线程2 执⾏之前, jay的朋友正好给jay转账 50, 账⼾余额变成 100 !!
4. 轮到线程2 执⾏了, 发现当前存款为 100, 和之前读到的 100 相同, 再次执⾏扣款操作

解决方案

（1）引用“版本号”

引起 ABA 问题的主要原因就是 CAS 能加也能减，导致CAS无法正确判断当前数据是否已经经过修改。但由于上述场景中的余额本身就是能加能减的，这时我们就可以引入新的概念“版本号”。

使用带有版本号的原子引用类型，如 AtomicStampedReference。这种类型的引用不仅包含了引用本身，还包含了一个版本号或标记。每次修改引用的同时也会更新版本号，这样即使引用值回到原来的值，版本号也会发生变化，从而避免了ABA问题。

import java.util.concurrent.atomic.AtomicStampedReference;public class ABASolutionExample {public static void main(String[] args) {AtomicStampedReference<Integer> ref = new AtomicStampedReference<>(0, 0);// 修改引用值int stamp = ref.getStamp();int reference = ref.getReference();reference = 1; // 修改引用值ref.compareAndSet(reference, reference, stamp, stamp + 1);// 回滚引用值reference = 0;ref.compareAndSet(reference, reference, stamp + 1, stamp + 2);// 尝试修改引用值boolean success = ref.compareAndSet(0, 2, stamp + 2, stamp + 3);System.out.println("CAS operation result: " + success);System.out.println("Current value: " + ref.getReference());}
}

上述代码中，我们创建了一个AtomicStampedReference，它包含了值0和版本号0。通过修改引用值和版本号，我们模拟了ABA问题。在尝试修改引用值时，由于版本号已经发生了变化，所以CAS操作会失败，从而避免了ABA问题的发生

（2）使用带有标记的指针：

  • 对于特定的应用场景，可以使用带有标记的指针来解决ABA问题。标记可以是一个额外的字段，用来记录值的版本信息。这种方法类似于使用AtomicStampedReference，但需要手动维护标记字段。

（2）使用条件变量：

  • 在某些情况下，可以通过引入条件变量来解决ABA问题。条件变量可以帮助线程等待某个条件成立，从而确保在进行CAS操作之前，值确实没有被修改过。

小结

在实际开发中，选择哪种方法来解决ABA问题取决于具体的应用场景和需求。如果ABA问题导致的后果不是特别严重，可以接受ABA问题的存在，因为引入版本号或标记字段会增加系统的复杂性。然而，在需要严格保证一致性的情况下，应该使用带有版本号的原子引用或其他适当的解决方案。

总的来说，解决ABA问题的关键在于引入某种形式的版本控制或标记机制，以确保即使值回到了原来的状态，也能识别出它曾经被修改过。这样可以有效地防止由于ABA问题导致的数据一致性问题。

总结

CAS作为一种高效的原子操作，对于并发编程有着重要的意义。它可以提高程序的并发性能，减少锁带来的开销。然而，它也存在一些固有的局限性，比如ABA问题、循环重试导致的CPU消耗等问题。在实际应用中，应根据具体的使用场景和需求来权衡是否使用CAS，以及如何合理地使用CAS来实现高效、可靠的并发控制。同时，可以结合其他同步机制来弥补CAS的不足，以达到更好的并发效果。

那么本篇文章就到此为止了，如果觉得这篇文章对你有帮助的话，可以点一下关注和点赞来支持作者哦。作者还是一个萌新，如果有什么讲的不对的地方欢迎在评论区指出，希望能够和你们一起进步✊

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

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

相关文章

深度学习-从零基础快速入门到项目实践，这本书上市了！！！

深度学习-从零基础快速入门到项目实践，这本书上市了！！！

此书地址&#xff1a; 《【2024新书】深度学习 从零基础快速入门到项目实践 文青山 跟我一起学人工智能 机器学习算法原理代码实现教程 深度学习项目分析 深度学习 从零基础快速入门到项目实践》【摘要 书评 试读】- 京东图书 除深度学习外我还写了一本软件测试书。我大概是国…
阅读更多...
高效编程的利器 Jupyter Notebook

高效编程的利器 Jupyter Notebook

目录 前言1. Jupyter Notebook简介1.1 功能特点1.2 使用场景 2. 不同编程工具的对比与效率提升2.1 VS Code&#xff1a;灵活且轻量的代码编辑器2.2 PyCharm&#xff1a;面向专业开发者的集成开发环境2.3 Git&#xff1a;高效协作的版本控制工具2.4 Jupyter Notebook 和 VS Code…
阅读更多...
idea中.git文件夹存在但是没有git功能列表

idea中.git文件夹存在但是没有git功能列表

1.问题&#xff1a; 该项目中已经将.git文件夹置入了&#xff0c;但是idea中却没有git相关的功能列表&#xff0c;如图&#xff1a; 2.解决办法&#xff1a; 在【文件】-【设置】-【版本控制】-【目录映射】中添加目录映射应用就好了 &#xff08;【File】 -> 【S…
阅读更多...
使用 Elasticsearch Reindex API 迁移数据

使用 Elasticsearch Reindex API 迁移数据

使用 Elasticsearch Reindex API 迁移数据 在 Elasticsearch 中&#xff0c;随着需求的变化&#xff0c;可能需要对索引进行重建或更新。这通常涉及创建新索引、迁移数据等步骤。本文介绍如何使用 Reindex API 将旧索引中的数据迁移到新索引中 一、步骤概述 创建新索引&#…
阅读更多...
LEAN 赋型唯一性（Unique Typing）之 并行 κ 简化 （Parallel κ reduction）＞＞ₖ

LEAN 赋型唯一性（Unique Typing）之 并行 κ 简化 （Parallel κ reduction）＞＞ₖ

基于 κ 简化 &#xff08;κ reduction&#xff09; 的概念&#xff0c;引入了并行简化&#xff08;Parallel Reduction&#xff09;的概念&#xff0c;记 >>&#xff0c;而 并行K简化&#xff08;Parallel K Reduction&#xff09;记为 >>ₖ 。直观的意思是&…
阅读更多...
Windows下利用MSYS2和VS的nmake编译nginx源码

Windows下利用MSYS2和VS的nmake编译nginx源码

目录 一、使用说明 二、安装软件 2.1 下载依赖库 2.3 下载并安装 StrawberryPerl 2.4 下载并安装 MSYS 2 2.5 nginx源代码下载 三、编译配置 3.1 设置NGX_MSVC_VER 3.2 配置 Makefile 3.3 编译代码 3.4 整理Nginx发布环境 四、错误处理 一、使用说明 本文章主要记…
阅读更多...
【正点原子K210连载】第四十章 YOLO2人手检测实验摘自【正点原子】DNK210使用指南-CanMV版指南

【正点原子K210连载】第四十章 YOLO2人手检测实验摘自【正点原子】DNK210使用指南-CanMV版指南

第四十章 YOLO2人手检测实验 在上一章节中&#xff0c;介绍了利用maix.KPU模块实现YOLO2的人脸检测&#xff0c;本章将继续介绍利用maix.KPU模块实现YOLO2的人手检测。通过本章的学习&#xff0c;读者将学习到YOLO2网络的人手检测应用在CanMV上的实现。 本章分为如下几个小节&…
阅读更多...
RocketMQ核心编程模型与最佳实践

RocketMQ核心编程模型与最佳实践

目录 一、RocketMQ的消息模型 1、RocketMQ客户端基本流程 2、消息确认机制 3、广播消息 4、顺序消息机制 5、延迟消息 6、批量消息 7、过滤消息 8、事务消息 9、ACL权限控制机制 二、SpringBoot整合RocketMQ 1、快速实战 2、如何处理各种消息类型 3、实现原理 三…
阅读更多...
周末愉快！——周复盘

周末愉快！——周复盘

加班的晚上有一个美梦&#xff01; 周末愉快简单复盘结尾 精华&#xff1a; 在这个信息爆炸的时代&#xff0c;我们的大脑每天都被无数的数据和刺激充斥&#xff0c;以至于我们常常感到应接不暇。然而&#xff0c;正如古人所言&#xff1a;“不飞则已&#xff0c;一飞冲天”&am…
阅读更多...
GraphRAG 与 RAG 的比较分析

GraphRAG 与 RAG 的比较分析

检索增强生成&#xff08;RAG&#xff09;技术概述 检索增强生成&#xff08;Retrieval-Augmented Generation&#xff0c;简称 RAG&#xff09;是一种旨在提升大型语言模型&#xff08;Large Language Models&#xff0c;LLMs&#xff09;性能的技术方法。其核心思想是通过整…
阅读更多...
容器化安装Jenkins部署devops

容器化安装Jenkins部署devops

基础环境介绍 系统使用的是centos7.9 内核使用的是5.16.13-1.el7.elrepo.x86_64 容器使用的是26.1.4 docker-compose使用的是 v2.29.0 链路图 devops 配置git环境插件 部署好jenkins后开始配置 jenkins连接git&#xff0c;这里需要jenkins有连接git的插件。在已安装的插件…
阅读更多...
豆包Python SDK接入流程

豆包Python SDK接入流程

模型与价格 豆包的模型介绍可以看豆包大模型介绍&#xff0c;模型价格可以看豆包定价文档里的“模型推理” - “大语言模型” - “字节跳动”部分。 推荐使用以下模型&#xff1a; Doubao-lite-32k&#xff1a;每百万 token 的输入价格为 0.3 元&#xff0c;输出价格为 0.6 元…
阅读更多...
Hexo博客私有部署Twikoo评论系统并迁移评论记录(自定义邮件回复模板)

Hexo博客私有部署Twikoo评论系统并迁移评论记录(自定义邮件回复模板)

部署 之前一直使用的artalk&#xff0c;现在想改用Twikoo&#xff0c;采用私有部署的方式。 私有部署 (Docker) 端口可以根据实际情况进行修改 docker run --name twikoo -e TWIKOO_THROTTLE1000 -p 8100:8100 -v ${PWD}/data:/app/data -e TWIKOO_PORT8100 -d imaegoo/twi…
阅读更多...
LabVIEW编程能力如何能突飞猛进

LabVIEW编程能力如何能突飞猛进

要想让LabVIEW编程能力实现突飞猛进&#xff0c;需要采取系统化的学习方法&#xff0c;并结合实际项目进行不断的实践。以下是一些提高LabVIEW编程能力的关键策略&#xff1a; 1. 扎实掌握基础 LabVIEW的编程本质与其他编程语言不同&#xff0c;它是基于图形化的编程方式&…
阅读更多...
nethogs显示每个进程所使用的带宽

nethogs显示每个进程所使用的带宽

1、安装nethogs&#xff1a; Ubuntu、Debian和Fedora用户可以从默认软件库获得。CentOS用户则需要Epel。 #ubuntu或debian安装方法 sudo apt-get install nethogs #fedroa或centos安装法 sudo yum install nethogs -y 2、使用测试 nethogs是一款小巧的"net top&quo…
阅读更多...
开源项目还需要花钱吗

开源项目还需要花钱吗

开源和免费并不完全等同&#xff0c;很多用户对开源软件是否真的不花钱存在误解。本文深入探讨开源的真正含义、开源项目是否需要付费、以及开源软件的盈利模式。通过分析国内外主流开源平台&#xff0c;我们将帮助读者更好地理解开源与免费之间的区别。 什么是开源 开源软件指…
阅读更多...
增强现实系列—GaussianAvatars: Photorealistic Head Avatar

增强现实系列—GaussianAvatars: Photorealistic Head Avatar

&#x1f31f;&#x1f31f; 欢迎来到我的技术小筑&#xff0c;一个专为技术探索者打造的交流空间。在这里&#xff0c;我们不仅分享代码的智慧&#xff0c;还探讨技术的深度与广度。无论您是资深开发者还是技术新手&#xff0c;这里都有一片属于您的天空。让我们在知识的海洋中…
阅读更多...
【ollama】ollama配置本地大模型并运行

【ollama】ollama配置本地大模型并运行

ollama的Github链接 https://github.com/ollama/ollamaollama官网链接 https://ollama.com/打开后点击下载 下载完成后进行安装&#xff0c;安装完毕后在终端输入以下&#xff0c;代表安装成功 ollama在ollama官网的模型库中找到需要的模型&#xff0c;这里使用阿里最新开源…
阅读更多...
ZYNQ FPGA自学笔记~操作PLL

ZYNQ FPGA自学笔记~操作PLL

一 时钟缓冲器、管理和路由 垂直时钟中心&#xff08;clock backbone&#xff09;将设备分为相邻的左侧和右侧区域&#xff0c;水平中心线将设备分为顶部和底部两侧。clock backbone中的资源镜像到水平相邻区域的两侧&#xff0c;从而将某些时钟资源扩展到水平相邻区域。BUFG不…
阅读更多...
JavaWeb---三层架构

JavaWeb---三层架构

文章目录 1. 为什么需要分层&#xff1f;2.软件设计中的分层模式3.分层4.三层架构&#xff1a;显示层、业务逻辑层、数据访问层3. 案例&#xff1a;利用三层架构原理实现编写web程序的流程 摘自&#xff1a;https://blog.csdn.net/qq_64001795/article/details/124112824 1. 为…
阅读更多...
最新文章

Copyright @ 2022~2023