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;通常是左右…

计算机网络13——IM聊天系统——网络功能实现——UDP

目录 1、类的成员变量 2、魔鬼数字 3、创建接收数据的线程 4、线程函数 5、防止旧接收到的数据被新数据覆盖掉 6、拷贝用的函数:memcpy_s 7、回收线程资源 8、计数器-1 (1)结束线程工作 (2)关闭句柄 测试代码 1、类的成员变量 同一个类中的多个函数中都要使用…

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&#…

单一职责原则介绍

一.概念介绍 单一职责原则(Single Responsibility Principle, SRP)是面向对象设计中的五大基本原则之一,它是指一个类或者模块应该仅有一个引起它变化的原因。 具体来说,单一职责原则有以下几个特点: 职责集中:一个类或模块应该专注于完成一种特定的功能或职责,而不应该承担过…

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;优化种植策略以最大化经济收益成为当前农业研究中的重要问题。本…

企微群发助手:提升企业微信营销效率的得力助手

在数字化营销的时代背景下&#xff0c;企业微信&#xff08;简称“企微”&#xff09;已成为众多企业与客户沟通、传播品牌信息的重要渠道。然而&#xff0c;随着客户群的日益庞大&#xff0c;如何高效、精准地进行群发消息&#xff0c;成为了企业面临的一大挑战。企微群发助手…

富格林:解析阻挠出金套路攻略

富格林指出&#xff0c;黄金投资处于剧烈的市场波动时&#xff0c;可以给投资者带来充分的盈利机会&#xff0c;让不少投资者都转向黄金市场。然而&#xff0c;对于新手小白来说&#xff0c;阻挠套路实现盈利出金并不像想象得那些简单。那么&#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 …

c# c++程序 交互

目录 一、两种不同程序写的进程交互 1、定义交互消息 2、定义C进程发来的消息ID 3、定义C进程交互的句柄 及给C进程发送的消息ID 4、定义交互消息所需的数据类型 5、引入所需的系统函数 6、给主进程发消息 7、写入本进程主窗口句柄 8、处理发来的交互消息 一、两种不…

【类模板中的友元】友元类

1.友元的概念 传统友元类的概念是&#xff1a;让某个类 B B B成为另外一个类 A A A的友元类&#xff0c;这样&#xff0c;类 B B B就可以在其成员函数中访问类 A A A的所有成员&#xff08;成员变量&#xff0c;成员函数等&#xff09;&#xff0c;而不管这些成员在类 A A A中…

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

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

Spark MLlib模型训练—聚类算法 Bisecting K-means

Spark MLlib模型训练—聚类算法 Bisecting K-means 由于传统的KMeans算法的聚类结果易受到初始聚类中心点选择的影响,因此在传统的KMeans算法的基础上进行算法改进,对初始中心点选取比较严格,各中心点的距离较远,这就避免了初始聚类中心会选到一个类上,一定程度上克服了算…