时间:2021-05-20
CAS操作号称无锁优化,也叫作自旋;对于一些常见的操作需要加锁,然后jdk就提供了一些以Atomic开头的类,这些类内部自动带了锁,当然这里的锁并非是用synchronized来实现的,而是通过CAS操作来实现的;
一、下面是 AtomicInteger 的使用:
二、当然达到使用的级别很简单,看一下API就好了,通过上面的小程序,下面主要来聊一聊原理:
1、通过源码分析AtomicInteger
首先小程序中定义了一个 AtomicInteger 类型的变量count;
调用了AtomicInteger类中incrementAndGet();
/** * Atomically increments by one the current value. * * @return the updated value */ public final int incrementAndGet() { return unsafe.getAndAddInt(this, valueOffset, 1) + 1; }调用unsafe类中的 getAndAddInt(Object var1, long var2, int var4)方法;
这里通过以上三步的操作,最终会进入Unsafe类这里调用的 compareAndSwapInt 意思就是比较然后交换,通过一个while循环,在这里转呀转,直到修改成功;
CAS(compareAndSwap)(比较并交换):原来想改变的值为0 ,现在想修改成1 ,这里想做到线程安全就必须要加synchronized,现在想用另外一种方式来替换加锁的方法,就是所谓的CAS操作;你可以把它想象成拥有三个参数的方法cas(V , Expected , NewValue); 第一个参数V是你要改的那个值,Expected第二个参数是你期望当前的值是多少(也就是如果没有线程修改的时,这个值应该是多少,如果不是期望值那就证明有别的线程修改过),NewValue是要设置的新值;
上图简单模拟了CAS操作的过程,当线程1和线程2同时读取了共享变量count = 0;在线程1修改的过程中,线程2已经将count值修改为1,那么在线程1修改的时候发现Expected值和V已经匹配不上了,证明已经有线程快我一步将count值改了(可能这里并发量大的时候已经有n多个线程已经修改过了),怎么办呢?那我只能将我的期望值修改成V的值、newValue 在这基础上加1,然后继续在这自旋操作,直到修改成功,这就是自旋操作;
2、Unsafe类(java并发包底层实现的核心)
CAS操作不需要加锁是如何做到的呢?原因就在于Unsafe这个类,这个类除了你使用反射之外,你是不能够直接使用的,这里不能使用的原因和ClassLoader有关系,所有AtomicXXX 类内部都是CompareAndSwap / CompareAndSet(新版jdk),这个类中存在好多native方法;
Unsafe类使Java拥有了像C语言的指针一样操作内存空间的能力,一旦能够直接操作内存,这也就意味着(1)不受JVM管理,也就意味着无法被GC,需要我们手动GC,稍有不慎就会出现内存泄漏。(2)Unsafe的不少方法中必须提供原始地址(内存地址)和被替换对象的地址,偏移量要自己计算,一旦出现问题就是JVM崩溃级别的异常,会导致整个JVM实例崩溃,表现为应用程序直接crash掉。(3)直接操作内存,也意味着其速度更快,在高并发的条件之下能够很好地提高效率。
CAS:CompareAndSwap,内存偏移地址(var2),预期值(var4),新值(var5)。如果变量在当前时刻的值和预期值expected相等,尝试将变量的值更新为新值(var5)。如果更新成功,返回true;否则,返回false。
/** * CAS操作 :Unsafe类中的本地方法 由于Java语言无法访问操作系统底层信息(比如:底层硬件设备等), * 这时候就需要借助C C++语言来完成了 * @param var1 对象 * @param var2 偏移量 * @param var4 期望值 * @param var5 新值 * @return 修改成功返回true 失败返回false */ public final native boolean compareAndSwapObject(Object var1, long var2, Object var4, Object var5); public final native boolean compareAndSwapInt(Object var1, long var2, int var4, int var5); public final native boolean compareAndSwapLong(Object var1, long var2, long var4, long var6);三、CAS操作带来的ABA问题
ABA问题说白了就是在线程进行CAS操作过程中有多个线程对这个共享变量进行修改,有加有减,兜兜转转又回到起始值,这时该线程浑然不知;打个不恰当的比喻:这个过程就好像你前女友跟你分手以后,在时隔一年之后又找你复合来了,说兜兜转转还是觉得你好,在此期间你前女友已经换了几个男朋友你却浑然不知,那个好看的她穿着你喜欢的小短裙,扎着清纯的马尾辫又回来,好了言归正传,意思就是结果是你期望的,可是这个值是经过很多版本的。
下面简单模拟ABA操作图:
如何解决ABA问题呢?
如果是int类型,最终的值也是你期望的,真的是没有所谓,你也不用去纠结这问题;如果你确实就想管一管,那就加一个版本号,做一次修改操作加一,比较检查时连带版本号一起检查。
基础类型:没有必要管,对你真的没有所谓;
引用类型:就像是你女朋友和你分手之后又复合,中间经历了多少个男朋友,这个是有所谓的,这时可以通过加版本号来解决;
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
在上篇文章给大家介绍了java多线程的实现方式,通过本文给大家介绍java多线程实例,对java多线程感兴趣的朋友一起学习吧首先给大家说下多线程的优缺点多线程的
这篇文章主要介绍了Java多线程状态及方法实例解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下首先介绍线程
本文承接上一篇文章《Java多线程实例详解(一)》。四.Java多线程的阻塞状态与线程控制上文已经提到Java阻塞的几种具体类型。下面分别看下引起Java线程阻
java多线程的同步方法实例代码先看一个段有关银行存钱的代码:classBank{privateintsum;publicvoidadd(intnum){sum
这篇文章主要介绍了java多线程加锁以及Condition类的使用实例解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋