JavaEE:多线程进阶(CAS)

文章目录

  • CAS
    • 什么是 CAS
      • CAS 伪代码
    • CAS有哪些应用
    • CAS的ABA问题
      • 什么是ABA问题
      • ABA问题带来的BUG
      • 解决方案


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;}

两种典型的不是"原子性"的代码:

  1. check and set (if 判定然后设定值)[上面的CAS就是这种形式]
  2. read and update (i++)

当多个线程同时对某个资源进行CAS操作,只能有一个线程操作成功,但是并不会阻塞其他线程,其他线程只会收到操作失败的信号.

CAS是乐观锁的一种实现方式

CAS有哪些应用

  1. 实现原子类
    标准库中提供了java.util.concurrent.atomic包,里面的类都是这种方式来实现的.
    在这里插入图片描述

    典型的就是AtomicInteger类,其中的getAndIncrement相当于i++操作

    AtomicInteger atomicInteger = new AtomicInteger(0);
    // 相当于 i++
    atomicInteger.getAndIncrement();
    

    伪代码实现:

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

    假设两个线程同时调用getAndIncrement
    1. 两个线程都读取value的值到oldValue中.(oldValue是一个局部变量,在栈上,每个线程有自己的栈)
    在这里插入图片描述
    2. 线程1先执行CAS操作.由于oldValue和value的值相同,直接进行对value赋值.

    CAS是直接读写内存的,而不是操作寄存器.
    CAS的读内存,比较,写内存操作是一条硬件指令,是原子的.

    在这里插入图片描述
    3. 线程2再执行CAS操作,第一次CAS的时候发现oldValue和value不相等,不能进行赋值,因此需要进入循环.
    在循环里重新获取value的值赋给oldValue
    在这里插入图片描述
    4. 线程2接下来第二次执行CAS,此时oldValue和value相同,于是直接执行赋值操作.
    在这里插入图片描述
    5. 线程1和线程2返回各自的oldValue的值即可.
    通过形如上述代码就可以实现一个原子类.不需要使用重量级锁,就可以高效的完成多线程的自增操作.

    本来check and set 这样的操作在代码角度不是原子的,但是在硬件层面上可以让一条指令完成这个操作,也就变成原子的了

  2. 实现自旋锁
    基于CAS实现更灵活的锁,获取到更多的控制权.
    自旋锁伪代码

    public class SpinLock {private Thread owner = null;public void lock(){// 通过 CAS 看当前锁是否被某个线程持有. // 如果这个锁已经被别的线程持有, 那么就⾃旋等待. // 如果这个锁没有被别的线程持有, 那么就把 owner 设为当前尝试加锁的线程. while(!CAS(this.owner, null, 	Thread.currentThread())){}}public void unlock (){this.owner = null;}
    }
    

CAS的ABA问题

什么是ABA问题

ABA问题:
假设存在两个线程t1和t2,有一个共享变量num,初始值为A.
接下来,线程t1想使用CAS把num的值改成Z,那么就需要

  1. 先读取num的值,记录到oldNum变量中
  2. 使用CAS判定当前num的值是否为A,如果为A,就修改成Z.
    但是,在t1执行这两个操作之间,t2线程可能把num的值从A改成了B,又从B改成了A.

线程t1的CAS是期望num不变就修改.但是num的值已经被t2给修改了,只不过又改成A了,这个时候t1究竟是否要更新num的值为Z呢?

到这一步,t1线程无法区分当前这个变量始终是A,还是经历了一个变化过程.
在这里插入图片描述

ABA问题带来的BUG

大部分的情况下,t2线程这样的一个反复横跳改动,对于t1是否修改num是没有影响的,但是不排除一些特殊情况.

假设我有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执行之前,我的朋友正好给我转了50,于是我的账户余额就变成了100!
  4. 轮到线程2执行了,发现当前存款为100,和之前读到的100相同,再次执行扣款操作

这个时候,扣款操作被执行了两次!都怪ABA!!!

解决方案

通过CAS也不是不能解决上述问题.

ABA是因为"余额"能加也能减,才会有ABA问题,如果只能加,不能减就可以解决上述问题.

哎呀,你这不是废话吗,余额怎么可能只加不减?!

别急,余额确实不可能,但是我们可以新建一个变量,让它只增不减.给它起个名字,就叫"版本号"好了.

具体操作如下:
我们可以给要修改的值,引入版本号,在CAS比较数据和当前值和旧值的同时,也要比较版本号是否符合预期.

  1. 如果当前版本号和读到的版本号相同,则修改数据,并把版本号+1.
  2. 如果当前版本号高于读到的版本号,那就操作失败(认为数据已经被修改过了)

在Java标准库中提供了AtomicStampedReference<E>类,这个类可以对某个类进行包装,在内部就提供了上面描述的版本管理功能.

本文到这里就结束啦~

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

刷题记录(2)

1. HWOD机试 - 模拟消息队列(100) package com.yue.test;import org.junit.Test;import java.util.ArrayList; import java.util.Arrays; import java.util.LinkedList; import java.util.List;/*** Author: 夜雨* Date: 2021-12-08-10:31* Description:* Version 1.0*/ public…

【Android】ViewPager基本用法总结

文章目录 一、添加ViewPager控件二、构建适配器类三、在 MainActivity 中设置适配器示例一&#xff1a;图片切换适配器MainActivity 示例二&#xff1a;Fragment切换适配器FragmentMainActivity ViewPager 是 Android 中一个用于在同一屏幕上滑动不同页面&#xff08;通常是左右…

OBS怎么设置录制配置?3个电脑录屏小技巧妥妥教会你

OBS Studio是一款广受好评的开源录屏和直播软件&#xff0c;它以其强大的功能和用户友好的操作界面而闻名。对于初次接触OBS的用户来说&#xff0c;可能会对软件的众多按钮感到困惑。本文将为你提供一份简洁明了的OBS录屏指南&#xff0c;帮助你快速上手。 演示机型&#xff1a…

Hive数据库与表操作全指南

目录 Hive数据库操作详解 创建数据库 1&#xff09;语法 2&#xff09;案例 查询数据库 1&#xff09;展示所有数据库 &#xff08;1&#xff09;语法 &#xff08;2&#xff09;案例 2&#xff09;查看数据库信息 &#xff08;1&#xff09;语法 &#xff08;2&#…

Simulink:循环计数器 Counter Free-Running

原文&#xff1a;Matlab生成stm32代码_matlab stm32-CSDN博客 使用“Counter Free-Running”模块进行计数&#xff0c;参数配置如下 此配置的意思为每0.5秒计数一次&#xff0c;计数的最大值为2^Nbits – 1&#xff0c;其中Nbits为所填的2&#xff0c;所以这里最大值为3。 示波…

【多线程】死锁

&#x1f970;&#x1f970;&#x1f970;来都来了&#xff0c;不妨点个关注叭&#xff01; &#x1f449;博客主页&#xff1a;欢迎各位大佬!&#x1f448; 文章目录 1. 死锁的三种情况1.1 一个线程一把锁&#xff08;同一个线程给同一个对象加两次锁的情况&#xff09;1.2 两…

彻底解决 node/npm, Electron下载失败相关问题, 从底层源码详解node electron 加速配置

最近玩了一下electron项目, 总是会遇到electron的下载失败问题, 于是看了一下node源码, 做一个记录. node/npm 加速配置 这个配置通过设置node配置里面的registry 这个配置项来完成加速. 配置方法 npm config set registry https://registry.npmmirror.com上面的命令就是将当…

【全网最全】2024年数学建模国赛C题超详细保奖思路+可视化图表+成品论文+matlab/python代码等(后续会更新

您的点赞收藏是我继续更新的最大动力&#xff01; 一定要点击如下的卡片&#xff0c;那是获取资料的入口&#xff01; 基于优化模型的农作物的种植策略 摘要 随着农业生产向集约化和智能化方向发展&#xff0c;优化种植策略以最大化经济收益成为当前农业研究中的重要问题。本…

车载测试协议:ISO-14229、ISO-15765、ISO-11898、ISO-26262【车企项目实操学习】②

FOTA模块中OTA的知识点&#xff1a;1.测试过程中发现哪几类问题&#xff1f; 可能就是一个单键的ecu&#xff0c;比如升了一个门的ecu&#xff0c;他的升了之后就关不上&#xff0c;还有就是升级组合ecu的时候&#xff0c;c屏上不显示进度条。 2.在做ota测试的过程中&#xff…

已入职华为!!关于我成功拿下华为大模型算法岗经验总结

方向:大模型算法工程师 整个面试持续了1小时10分钟&#xff0c;能够看出面试官是典型搞技术的&#xff0c;问的很专业又很细&#xff0c;全程感觉压力好大&#xff0c;面完后感觉丝丝凉意&#xff0c;不过幸好还是成功拿下了Offer 一面: 自我介绍 简历项目深度交流 1.项目的背…

Java笔试面试题AI答之JDBC(2)

文章目录 7. 列出Java应该遵循的JDBC最佳实践&#xff1f;8. Statement与PreparedStatement的区别,什么是SQL注入&#xff0c;如何防止SQL注入Statement与PreparedStatement的区别什么是SQL注入如何防止SQL注入 9. JDBC如何连接数据库&#xff1f;1. 加载JDBC驱动程序2. 建立数…

[网络原理]关于网络的基本概念 及 协议

文章目录 一. 关于网络的概念介绍1. 局域⽹LAN2. ⼴域⽹WAN3. 主机4. 路由器5. 交换机IP地址端口号 二. 协议协议分层TCP/IP五层模型(或四层)OSI七层模型封装分用 一. 关于网络的概念介绍 1. 局域⽹LAN 局域⽹&#xff0c;即 Local Area Network&#xff0c;简称LAN。 Local …

二叉树的层次遍历(10道)

&#xff08;写给未来遗忘的自己&#xff09; 102.二叉数的层序遍历&#xff08;从上到下&#xff09; 题目&#xff1a; 代码&#xff1a; class Solution { public: vector<vector<int>> levelOrder(TreeNode* root) { vector<vector<int>> r…

JVM系列(十) -垃圾收集器介绍

一、摘要 在之前的几篇文章中,我们介绍了 JVM 内部布局、对象的创建过程、运行期的相关优化手段以及垃圾对象的回收算法等相关知识。 今天通过这篇文章,结合之前的知识,我们一起来了解一下 JVM 中的垃圾收集器。 二、垃圾收集器 如果说收集算法是内存回收的方法论,那么…

稀土废水回收硫酸铵树脂技术

稀土废水回收硫酸铵的过程主要涉及到化学沉淀法、离子交换法和蒸发结晶法等技术。这些方法可以有效地从稀土废水中回收硫酸铵&#xff0c;同时降低废水中的氨氮含量&#xff0c;实现资源的循环利用。以下是具体的技术介绍&#xff1a; 稀土废水回收硫酸铵的技术 ● 化学沉淀…

【MATLAB】矩阵的合并

矩阵的合并是指将两个或者多个矩阵合并到一起构成一个新的矩阵。矩阵标识符方括号 [ ]&#xff0c;不仅可以用来创建新的矩阵&#xff0c;还可以用来将若干个矩阵合并到一起。表达式 C [A B] 将矩阵A和B在水平方向上合并到一起&#xff0c;而表达式C[A;B]则将矩阵A和B在竖直方…

java项目docker部署时进行热部署

本文需要pontwiner进行配合操作 1.上传文件到对应服务器&#xff0c;可以通过xftp等文件上传工具进行文件上传 2.获取docker imagId XX为项目部署名称 例如&#xff1a;test-server docker ps -a |grep XX 3.复制文件到docker容器的/tmp目录下 docker cp XXXX.class im…

WEB服务与虚拟主机/IIS中间件部署

WWW&#xff08;庞大的信息系统&#xff09;是基于客户机/服务器⽅式的信息发现技术和超⽂本技术的综合。网页浏览器//网页服务器 WWW的构建基于三项核⼼技术&#xff1a; HTTP&#xff1a;超文本传输协议&#xff0c;⽤于在Web服务器和客户端之间传输数据。HTML&#xff1a;⽤…

工业制造企业如何与供应商间 进行高效安全的企业间文件传输?

工业制造企业的供应商数量通常较多&#xff0c;这主要是由于工业制造行业的复杂性和多元化特点所决定的。工业制造企业的产品结构往往较为复杂&#xff0c;涉及到多种原材料、零部件和设备。这些物资的需求不仅数量大&#xff0c;而且种类繁多&#xff0c;因此需要与多个供应商…

HR招聘新员工,如何考察企业文化适配度

要解决文化适配性问题&#xff0c;那在招聘过程中一定要明确企业核心价值观。比如通过制定明确文化价值观手册的方式&#xff0c;向求职者展示企业的使命愿景和价值观。 目前最为理想的考察方式就是线上的人才测评&#xff0c;比如&#xff1a;采用职业价值观测评法&#xff0…