面试被问到CAS原理,触及知识盲区,脸都绿了!

面试被问到CAS原理,触及知识盲区,脸都绿了!CAS底层原理想要了解CAS底层原理,那么我们先来了解一下JUC包的一个类即:AtomicInteger。那么这个AtomicInteger有什么用呢?我们平时开发或多或少都会使用到i++这个操作,那么稍微了解多线程的同学都会知道,在多线程环境下,i++操作是线程不安全的操作,譬如下面这段代码:publicclassMain{privateinti=0;publicvoidaddI(){i++;}..

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE稳定放心使用


前提知识掌握

想要了解 CAS 底层原理,那么我们先来了解一下 java.uit.concurrent即JUC包的一个类即:AtomicInteger

那么 这个 AtomicInteger 有什么用呢 ?

我们平时开发或多或少都会使用到 i++ 这个操作,那么稍微了解多线程的同学都会知道,在多线程环境下,i++ 操作是线程不安全的操作,譬如下面这段代码:

public class Main { 
   

    private int i = 0;

    public void addI() { 
   
        i++;
    }

    public static void main(String[] args) throws InterruptedException { 
   
        Main main = new Main();
        for (int i = 1; i <= 100; i++) { 
   
            new Thread(() -> { 
   
                for (int j = 1; j <= 200; j++) { 
   
                    main.addI();
                }
            },String.valueOf(i)).start();
        }
        //两个线程 主线程 和 垃圾回收线程
        while (Thread.activeCount() > 2) { 
   
            Thread.yield();
        }
        System.out.println(Thread.currentThread().getName() + "\t" + main.i);
    }

}

这段代码很简单,就是开启100个线程,每个线程进行200次 i++操作,那么我们来看看最后的答案:

在这里插入图片描述

正常来说这个 i 最后的值应该是 20000,但是这里却是19884,当然来,并不是这个值每次都是19884,小伙伴们可以多试几次,但这些值都有一个共同的特性,就是基本上都是小于20000的(当然可能有时候就是20000,可以把线程数开多点,或者每个线程进行 i++次数弄多点)。

这是为什么呢?

原因就是:i++其实不是一个原子性操作,什么叫原子性操作?简单来说就是不可再拆分的操作,而 i++是可以继续拆分的操作,即非原子性操作,它的操作可以分为以下三步:

  1. 取出 i 的值
  2. 将 i 的值 进行 +1
  3. 将 i+1 后的值写回给 i(也就是写回给主内存)

这里涉及到 Java内存模型,不清楚的小伙伴可以参考参考这篇博文哦 ——> Java 内存模型(JMM)、happens-before规则(先行发生规则) 你能知多少?

假设: 现在 i = 1,在多线程环境中,可能线程A正在进行第二步操作,但此时线程B飞快地完成这三部操作,那么此时 i 的值为2,但是线程A并不知道 i 已经为2了,它还会继续往下执行,那么对于线程A来说 会将 i+1的值写回给 i 也就是将 2写回给i,那么最后 i 的值为2不是3就错误了。

那么就会有小伙伴说了,照你这么说直接用 volatile 修饰 i 不就行了。
在这里插入图片描述

话不多说,先上代码

在这里插入图片描述

在这里插入图片描述

这是为什么呢?

我们都知道 volatile进行写操作时会把最新的变量值强制刷新到主内存,还会导致其他线程里的缓存无效。也就是说,当线程B完成i++操作之后,线程A缓存的 i 的值会无效。

在这里插入图片描述

但是
我们设想一下这样的场景, i = 10,如果线程A完成i+1操作后准备写回到主内存时阻塞了,此时B线程来了,上来就是一套 接——>化——>发,哦不不不,是一套拷贝、赋值、写入,啪一下,很快啊,B就搞完了,此时 i 为11,那么虽说由volatile保证可见性,但是A线程的+1操作已经完成,准备写入,所以此时A没有阻塞之后,继续进行写入操作,最终 i 的值就是A写入的值,即11,所以没有保证原子性,出现了线程不安全问题。

在这里插入图片描述

那么到底要怎么解决呢?

就是使用我一开始提到的 AtomicInteger 解决这类问题,代码如下:

在这里插入图片描述

可以看到结果是正确的,为此我还专门 调大了线程数和每个线程的i++次数,可结果仍然正确。

但这些只是前戏

在这里插入图片描述


什么是CAS?

CAS中文翻译就是 比较并交换(Compare And Swap)

CAS操作包括了3个操作数:

  1. 需要读写的内存位置(V)
  2. 进行比较的预期值(A)
  3. 拟写入的新值(B)

当且仅当如果内存位置V的值等于预期的A值,则将该位置更新为新值B,否则不进行任何操作。许多CAS的操作是自旋的:如果操作不成功,会一直重试,直到操作成功为止。

但是既然涉及到了 交换 ,那么怎么保证原子性呢 ?

答案:CAS是由CPU支持的原子操作,其原子性是在硬件层面进行保证的。


CAS原理

那么今天的重点就是:CAS的实现原理,而AtomicInteger底层就是使用到的CAS。

public class Main { 
   


    public static void main(String[] args) throws InterruptedException { 
   

        AtomicInteger num = new AtomicInteger(0);
        num.getAndIncrement();
    }

}

在这里插入图片描述
在这里插入图片描述

而 compareAndSwapInt 是个 native方法
在这里插入图片描述

可以看见 getAndIncrement() 方法返回的是 unsafe.getAndAddInt(this, valueOffset, 1);

那么,这个 this就是当前的 AtomicInteger 对象,而valueOffset 是当前 AtomicInteger对象 value值的内存偏移量,而1 是每次需要增加的值。

面试被问到CAS原理,触及知识盲区,脸都绿了!

那么继续往下走就是 getAndAddInt() 方法

根据 一 一对应关系

  • var1 = this
  • var2 = valueOffset
  • var4 = 1

而 this.getIntVolatile(var1, var2); 可以理解为获取 var1对象对应的内存偏移量var2对应的值,赋值给 var5

最后是 compareAndSwapInt(var1, var2, var5, var5 + var4),即理解为如果当前 var1对象对应的var4内存偏移量所对应的值与var5相等的话,就对值进行更新。

    public final int getAndAddInt(Object var1, long var2, int var4) { 
   
        int var5;
        do { 
   
            var5 = this.getIntVolatile(var1, var2);
        } while(!this.compareAndSwapInt(var1, var2, var5, var5 + var4));

        return var5;
    }

完犊子,不知不觉把 AtomicInteger 原理也讲了,这不就少写一篇博文,?


既然讲了,那就小总结一下吧:

AtomicInteger实现原理简单来说就是 Unsafe类 加 自旋(do while循环),如果在详细点就说 CAS嘛。

也可以说AtomicInteger是 CAS的一个使用场景,不仅是AtomicInteger,还有各种Atomic开头的原子类,内部都应用到了CAS。

而且上文中涉及到的 Unsafe类是 CAS的核心类,因为Java方法无法访问底层系统,所以需要通过 上文中的 compareAndSwapInt 这样的 native方法来进行访问Unsafe类存在于sun.misc包中,提供硬件级别的原子操作。

在这里插入图片描述


CAS带来的问题

  • ABA问题 解决办法 → 如何解决 CAS 的 ABA问题
  • 如果自旋长时间不成功,那么循环开销时间大
  • 只能保证一个共享变量的操作 → 可以使用 AtomicReference 解决

本篇博文到此页也结束了

等等

读者大大:好歹总结一下CAS原理吧

皮皮虾:时刻为您效劳,只要点赞什么都好说(手动滑稽)


CAS原理总结,面试问到了到底该怎么说?

答:CAS是一种乐观锁机制具体实现为 Unsafe类 + 自旋,通过Unsafe类提供硬件级别的原子性操作保证了并发安全,加上自旋操作,解决了 synchronized 在多线程环境下会出现的线程阻塞,唤醒切换,以及用户态内核态间的切换操作所带来的消耗。在由此扩展到 AtomicInteger也就是我上面讲的一套说给面试官,绝对 OK!


尾言

我是 Code皮皮虾,一个热爱分享知识的 皮皮虾爱好者,未来的日子里会不断更新出对大家有益的博文,期待大家的关注!!!

创作不易,如果这篇博文对各位有帮助,希望各位小伙伴可以一键三连哦!,感谢支持,我们下次再见~~~

分享大纲

大厂面试题专栏

Java从入门到入坟学习路线目录索引

开源爬虫实例教程目录索引

更多精彩内容分享,请点击 Hello World (●’◡’●)


在这里插入图片描述

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/181155.html原文链接:https://javaforall.net

(0)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

  • latex IEEEtran bib参考文献title双引号

    latex IEEEtran bib参考文献title双引号1.我想在其他latex文档中,使用IEEEtran.bst所定义的格式去引用参考文献,我的参考文献的具体信息存放在cankao.bib文件中了;然后我就使用下面两句引用参考文献;文献也能引用,也能正常显示,就是title上没有双引号,与IEEE提供的模板出现的参考文献有些差异;\bibliographystyle{IEEEtran}\bibliography{IEEEabrv,cankao}{}2.我这个傻叉捣鼓了两天,发现我所使用的文档中有一个语句已经定义了参考文献的格式,语句的内容如下

    2022年6月25日
    44
  • pycharm2021.3激活码破解方法

    pycharm2021.3激活码破解方法,https://javaforall.net/100143.html。详细ieda激活码不妨到全栈程序员必看教程网一起来了解一下吧!

    2022年3月14日
    372
  • 搭建Eurake集群

    搭建Eurake集群eureka作为SpringCloud的服务发现与注册中心,在整个的微服务体系中,处于核心位置。单一的eureka服务,显然不能满足高可用的实际生产环境,这就要求我们配置一个能够应对各种突发情况,具有较强容灾能力的eureka集群服务。其实我们只需要在部署时候,对eureka的配置文件做相应的修改,运行即可。在项目中,创建三个名字分别为eureka01,eureka02,eureka03的eur…

    2022年6月4日
    39
  • redis实现订单支付(延时队列)

    redis实现订单支付(延时队列)在电商网站中,我们经常会遇到订单支付,退货时间问题,那么怎么去处理那?设置定时任务,使用liunx中的at定时就可以轻松搞定,这里不在过多的研究使用redis延时队列:redis有一个数据类型,Sset叫做可以排序的集合(有序集合),为什么会是有序的那,是因为它与set相比有个属性叫score,sset就是这个属性(字段)来排序的,那如何实现延时队列那?实现方法:利用zset保存队列信息,score按照时间戳存放,再启动一个任务(线程),一直扫这个zset,判断当前时间和队列中的时间大小信息,如

    2022年6月5日
    160
  • hackbar2.2.9在Firefox中的安装

    hackbar2.2.9在Firefox中的安装转载出处:https://www.ddosi.com/b320/尊重原创,以及知识产权,首先声明这是上面链接中大神的辛苦劳动成果,因为不知道如果联系所以这篇转载可能会有侵权问题,希望查看此链接的爱好者直接点击上面的链接查看,这篇仅是个人学习转载。前言众所周知,Firefox的插件必须经过签名,才能加载到浏览器中.因此,对于hackbar的破解,要么是装2.1.3这个没有激活的老版本,要么是直接安装hackbar的替代品,如Machackbar……其实对于h.

    2022年5月15日
    76
  • linux 中jenkins启动/重启/停止命令 改端口

    linux 中jenkins启动/重启/停止命令 改端口jenkins启动#servicejenkinsstart重启#servicejenkinsrestart停止#servicejenkinsstop默认jenkins端口是8080,如果是jenkins的war包方式启动1.到war包目录执行下面的命令#java-jarjenkins.war–ajp13Port=-1–httpPort=808…

    2022年6月2日
    135

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号