Java并发编程之CAS二源码追根溯源

在上一篇文章中,我们知道了什么是CAS以及CAS的执行流程,在本篇文章中,我们将跟着源码一步一步的查看CAS最底层实现原理。

本篇是《凯哥(凯哥Java:kagejava)并发编程学习》系列之《CAS系列》教程的第二篇:从源码追根溯源查看CAS最底层是怎么实现的。

本文主要内容:CAS追根溯源,彻底找到CAS的根在哪里。

一:查看AtomicInteger.compareAndSet源码

通过上一篇文章学习,我们知道了AtomicInteger.compareAndSet方法不加锁可以保证原子性(其原理就是unsafe+cas实现的),我们来看看其源码:

思考1:变量可见性

AtomicInteger对象(下文凯哥简称:atoInteger)怎么保证变量内存可见性呢?

查看源码:

思考2:为什么上一篇13行的i.compareAndSet(1,1024)是false

我们来看看atoInteger的compareAndSet方法。凯哥在上面添加了注释。

在调用unsafe的compareAndSwapInt这个方法的时候,unsafe是什么?this指的是什么?valueOffset又是什么呢?

我们接着查看atoInteger源码:

我们发现Unsafe以及valueOffset都是从一个对象中获取到的。

那么this指的是什么?其实this就是当前atoInteger对象。

那么Unsafe对象在哪里呢?

我们想要看源码,怎么查看呢?发现不能看源码啊。别急,这个文件的源码可以从openJdk的源码中查到。

接着,我们来查看OpenJdk8的源码:

(PS:下载OpenJdk8源码凯哥这里就不赘述了。在文章最后,凯哥给出)

下载完,解压之后,文件位置:openjdk\jdk\src\share\classes\sun\misc。如下图:

我们来看看Unsafe类上面的注解:

A collection of methods for performing low-level, unsafe operations.

什么意思呢?用于执行底层的(low-level,)、不安全操作的方法的集合。

就是说,这个类可以直接操作底层数据的。

需要说明的是:在这个对象中大量的方法使用了native来修饰(据网友统计高达82个)

我们知道,Java的方法使用native关键字修饰的,说明这个方法不是Java自身的方法(非Java方法),可能调用的是其他语言的。如C或C++语言的方法。

我们再来看看:unsafe.objectFieldOffse()中的

这个方法就是返回一个内存中访问偏移量。

return unsafe.compareAndSwapInt(this, valueOffset, expect, update);

在unsafe类中compareAndSwapInt方法也是native的。我们在来看看这个方法调用操作系统底层C++的代码:

说明:

jint *addr:主内存中的变量值

old:对象工作区域的值

new_val:将要改变的值。

这三个是不是很熟悉,对。就是CAS的三个参数。

分析第13行为什么返回false:

在11行的时候,设置主内存的变量值V=1.

在12行后,更新为V=2020了。

当执行到第13行的时候,

主内存:V=2020

程序工作区变量值jint *addr A的值:A=1

new_val:1024。

从调用C++代码我们可以分析到:

在第5行的时候,因为1!=2020,所以return 的result就是false.

所以第13行输出的是false.

思考3:atoInteger.getAndIncrement()是怎么保证数据一致性的

调用的是getAndAddInt方法。接着查看unsafe的源码,就会发现CAS保证原子性的终极代码。

CAS保证原子性终极方法,如下图:

看看:getObjectVolatile。方法发现是native.如下图:

再来看看compareAndSwapObject:

发现是native修饰的方法。说明不是Java的方法。这个我们等会再细说。

先来研究getAndSetObject:

源码:

我们来模拟:atoInteger.getAndIncrement();

假设默认值是0. 主内存的值是0

在调用getAndSetObject方法的几个参数说明:

Var1:当前atoInteger对象

Var2:当前偏移量(内存地址所在位置。如:三排四列)

Vart4:默认就是1

Var5:获取到的主内存的值

Var5+var4:将要更新的值。

从源码,我们看到是do while语句。为什么不是while语句呢?因为先要获取到主内存中变量最新的值,然后再判断。所以选用了do while语句。

我们来看看当CPU1线程1和CPU2线程B来执行的时候:

两个线程都从主内存copay了i的值到自己工作内存空间后,进行+1的操作。

假设线程1再执行+1操作后,准备往主内存回写数据的时候,CPU1被挂起。然后CPU2竞争到资源之后,也操作i+1后,将更新后的值回写到了主内存中。然后切换到CPU1了,CPU1接着执行。对比代码分析:

线程1在执行do后得到的值var5=1而不是0

然后while里面执行:var1和var2运算后的结果是0(工作区的值)。

因为0!=5 .所以this.comparAndSwapInt的值是false.

又因为前面有个! 非得符号。也就是!false。我们知道!false就是true.

也就是while(true)。While(true)后,接着循环执行。线程会放弃原有操作,重新从主内存中获取到最新数据(此时就是1了),然后再进行操作后。

又到了do,获取在主内存最新数据是1.接着走while()

因为,var1,var2获取到工作区的值是1 var5也等于1.1=1,成立了,执行var5+var5=1+1=2,来更新主内存的数据后返回true.

又因为前面有个!非的符号。所以就是while(!true),也就是while(false)。退出循环,返回var5的值。

结论:

通过上面的运行分析,我们发现atoInteger的getAndIncrement方法保证原子性是unsafe+CAS来保证变量原子性的(其中do while语句就是后面我们将要学到的自旋)

原文地址:https://www.cnblogs.com/kaigejava/p/12571218.html

时间: 2024-11-11 13:59:29

Java并发编程之CAS二源码追根溯源的相关文章

Java并发编程之StampedLock锁源码探究

StampedLock是JUC并发包里面JDK1.8版本新增的一个锁,该锁提供了三种模式的读写控制,当调用获取锁的系列函数的时候,会返回一个long 型的变量,该变量被称为戳记(stamp),这个戳记代表了锁的状态. try系列获取锁的函数,当获取锁失败后会返回为0的stamp值.当调用释放锁和转换锁的方法时候需要传入获取锁时候返回的stamp值. StampedLockd的内部实现是基于CLH锁的,CLH锁原理:锁维护着一个等待线程队列,所有申请锁且失败的线程都记录在队列.一个节点代表一个线程

Java并发编程之CAS

http://www.cnblogs.com/lintong/p/4373723.html http://blog.csdn.net/hsuxu/article/details/9467651

Java并发编程之set集合的线程安全类你知道吗

Java并发编程之-set集合的线程安全类 Java中set集合怎么保证线程安全,这种方式你知道吗? 在Java中set集合是 本篇是<凯哥(凯哥Java:kagejava)并发编程学习>系列之<并发集合系列>教程的第二篇: 本文主要内容:Set集合子类底层分别是什么?基于底层为什么set的子类可以存放一个数据?怎么解决set线程安全问题? 一:Set集合子类 Set的三个子类分别是:HaseSet.TreeSet.LinkedHashSet.这三个都是线程不安全的.那么这三个子类

Java并发编程之ConcurrentHashMap

ConcurrentHashMap ConcurrentHashMap是一个线程安全的Hash Table,它的主要功能是提供了一组和HashTable功能相同但是线程安全的方法.ConcurrentHashMap可以做到读取数据不加锁,并且其内部的结构可以让其在进行写操作的时候能够将锁的粒度保持地尽量地小,不用对整个ConcurrentHashMap加锁. ConcurrentHashMap的内部结构 ConcurrentHashMap为了提高本身的并发能力,在内部采用了一个叫做Segment

Java高性能编程之CAS与ABA及解决方法

Java高性能编程之CAS与ABA及解决方法 前言 如果喜欢暗色调的界面或者想换换界面,可以看看我在个人博客发布的 Java高性能编程之CAS与ABA及解决方法. CAS概念 CAS,全称Compare And Swap,比较与交换. 属于硬件级别的同步原语,从处理器层面提供了内存操作的原子性. 从概念上,我们可以得出三点.第一,CAS的运作方式(通过比较与交换实现).第二,硬件层面支持,性能肯定不低(当然它也不是银弹).第三,提供原子性,那么它的功能肯定是确保原子性,从而确保线程安全. 实际使

java并发编程之Master-Worker模式

Master-Worker模式适合在一个任务可以拆分成多个小任务来进行的情况下使用. package cn.fcl.masterworker; import java.util.HashMap; import java.util.Map; import java.util.Queue; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentLinkedQueue; public c

Java并发编程之volatile的理解

Java并发编程之volatile关键字的理解 Java中每个线程都有自己的工作内存,类比于处理器的缓存,线程的工作内存中保存了被该线程使用到的变量的主内存的拷贝.线程读写变量都是直接在自己的工作内存中进行的,而何时刷新数据(指将修改的结果更新到主存或者把主存的变量读取覆盖掉工作内存中的值)是不确定的. volatile关键字是修饰字段的关键字,貌似是JDK1.5之后才有的,在多线程编程中,很大的几率会用到这个关键字,volatile修饰变量后该变量有这么一种效果:线程每一次读该变量都是直接从主

java并发编程之future模式

1.当你想并发去执行一段代码,但是还想获取这段代码的返回结果,那么future多线程模式就可以派上用场了,代码实现如下. public class Client { public Data request() { final FutureData futureData = new FutureData(); new Thread(new Runnable() { @Override public void run() { futureData.setRealData(new RealData()

java并发编程之Guarded Suspention

当客户端请求速度远远大于服务端的处理速度,这时候就非常适合使用Guarded Suspention模式 package cn.fcl.guardendSuspension; import java.util.ArrayList; import java.util.List; public class RequestQueue { private List<Integer> integers = new ArrayList<Integer>(); public synchronize