一、概述  

  Java从JDK1.5开始提供了java.util.concurrent.atomic包,方便程序员在多线程环境下无锁的进行原子操作。原子变量的底层使用了处理器提供的原子指令,但是不同的CPU架构可能提供的原子指令不一样,也有可能需要某种形式的内部锁,所以该方法不能绝对保证线程不被阻塞。

  atomic包里的类基本都是使用Unsafe实现的包装类,在Atomic包里一共有12个类,四种原子更新方式,这里我们将对着四种方式进一步分析。

二、解析
  1. 原子更新基本类型类
  用于通过原子的方式更新基本类型,Atomic包提供了以下三个类:
    AtomicBoolean:原子更新布尔类型。
    AtomicInteger:原子更新整型。
    AtomicLong:原子更新长整型。

  这里我们着重介绍下AtomicInteger这个类的常用方法,如下:
  (1)int addAndGet(int delta) :

    以原子方式将输入的数值与实例中的值(AtomicInteger里的value)相加,并返回结果
  (2)boolean compareAndSet(int expect, int update) :

    如果输入的数值等于预期值,则以原子方式将该值设置为输入的值。
  (3)int getAndIncrement():

    以原子方式将当前值加1,注意:这里返回的是自增前的值。
  (4)void lazySet(int newValue)
  (5)int getAndSet(int newValue):

    以原子方式设置为newValue的值,并返回旧值。

  参考实例如下:

      AtomicInteger a = new AtomicInteger(1);a.addAndGet(2); System.out.println(a); //3a.getAndIncrement();System.out.println(a.get()); //4

 这里我们延伸一下,介绍下CAS的实现原理:

  CAS(Compare and Swap,比较并操作),  CAS是项乐观锁技术,当多个线程尝试使用CAS同时更新同一个变量时,只有其中一个线程能更新变量的值,而其它线程都失败,失败的线程并不会被挂起,而是被告知这次竞争中失败,并可以再次尝试。

  CAS有3个操作数,内存值V,旧的预期值A,要修改的新值B。当且仅当预期值A和内存值V相同时,将内存值V修改为B,否则什么都不做。

AtomicInteger中的 incrementAndGet 方法源码如下:

  public final int getAndIncrement() {for (;;) {int current = get();int next = current + 1;if (compareAndSet(current, next))return current;}}

   通过源码可以看到,方法执行步骤为:先获取到当前的 value 属性值,然后将 value 加 1,赋值给一个局部的 next 变量,然而,这两步都是非线程安全的,但是内部有一个死循环,不断去做compareAndSet操作,直到成功为止,也就是修改的根本在compareAndSet方法里面,compareAndSet()方法的代码如下:

    public final boolean compareAndSet(int expect, int update) {return unsafe.compareAndSwapInt(this, valueOffset, expect, update);}

  compareAndSwapInt 方法是一个native 方法,如下:

  public final native boolean compareAndSwapInt(Object var1, long var2, int var4, int var5);    所以compareAndSet传入的值为执行方法时获取到的value属性值,next为加 1 后的值,compareAndSet调用native的compareAndSwapInt方法来完成,compareAndSwapInt 基于的是CPU的CAS指令来实现的。所以基于CAS的操作可认为是无阻塞的,一个线程的失败或挂起不会引起其它线程也失败或挂起。并且由于CAS操作是CPU原语,所以性能比较好。  但是需要注意的是:在CAS操作中,会出现ABA的问题,即如果V值先由A变为B,再由B变为A,那么会仍然认为是发生了变化,并需要重新执行算法中的步骤。  对应的解决方案是:不只更新某个引用的值,而是更新两个值,包括一个引用和一个版本号,即使这个值由A变为B,然后又变为A,版本号也是不同的。  例如:AtomicMarkableReference和AtomicStampedReference支持在两个变量上执行原子的条件更新,AtomicStampedReference更新一个“对象-引用”二元组,通过在引用上加上“版本号”,从而避免ABA问题,AtomicMarkableReference将更新一个“对象引用-布尔值”的二元组。

 2. 原子更新数组类

  通过原子的方式更新数组里的某个元素,Atomic包提供了以下三个类:
    AtomicIntegerArray:原子更新整型数组里的元素,主要用于原子的方式更新数组里的整型。
    AtomicLongArray:原子更新长整型数组里的元素。
    AtomicReferenceArray:原子更新引用类型数组里的元素。

  这里我们同样着重介绍下AtomicIntegerArray类的常用方法,如下:

  (1)int addAndGet(int i, int delta):

    以原子方式将输入值与数组中索引i的元素相加。
  (2)boolean compareAndSet(int i, int expect, int update):

    如果当前值等于预期值,则以原子方式将数组位置i的元素设置成update值。

  参考实例如下:

  int[] arr = new int[]{1,2,3};  AtomicIntegerArray arr1= new AtomicIntegerArray(arr);  arr1.getAndAdd(2,4);  arr1.getAndSet(0,2);  System.out.println(arr[2]); //3  System.out.println(arr1.get(2)); //7

  注:AtomicIntegerArray对内部的数组元素进行修改时,不会影响到传入的数组,原因是数组值通过构造方法传递进去,然后AtomicIntegerArray会将当前数组复制一份。

 3. 原子更新引用类型

  原子更新基本类型的AtomicInteger,只能更新一个变量,如果要原子的更新多个变量,就需要使用这个原子更新引用类型提供的类。Atomic包提供了以下三个类:
    AtomicReference:原子更新引用类型。
    AtomicReferenceFieldUpdater:原子更新引用类型里的字段。
    AtomicMarkableReference:原子更新带有标记位的引用类型。可以原子的更新一个布尔类型的标记位和引用类型。构造方法是AtomicMarkableReference(V initialRef, boolean initialMark)

  参考实例如下:

  static class User{String id;String name;volatile int age;public User(String id, String name, int age) {this.id = id;this.name = name;this.age = age;}public String getId() {return id;}public String getName() {return name;}public int getAge() {return age;}}public static void main(String[] args) {User user1 = new User("1", "LiLei", 11);User user2 = new User("2", "HanMeimei", 12);AtomicReference<User> user = new AtomicReference<User>(user1);System.out.println(user1.getName());  //LiLeiuser.getAndSet(user2);System.out.println(user.get().getName()); //HanMeimei }   

 4. 原子更新字段类

  如果我们只需要某个类里的某个字段,那么就需要使用原子更新字段类,Atomic包提供了以下三个类:
    AtomicIntegerFieldUpdater:原子更新整型的字段的更新器。
    AtomicLongFieldUpdater:原子更新长整型字段的更新器。
    AtomicStampedReference:原子更新带有版本号的引用类型。该类将整数值与引用关联起来,可用于原子的更数据和数据的版本号,可以解决使用CAS进行原子更新时,可能出现的ABA问题。
  原子更新字段类都是抽象类,每次使用都时候必须使用静态方法newUpdater创建一个更新器。原子更新类的字段的必须使用public volatile修饰符。

  AtomicIntegerFieldUpdater的例子代码如下:

  AtomicIntegerFieldUpdater<User> userUpdate = AtomicIntegerFieldUpdater.newUpdater(User.class, "age");userUpdate.getAndIncrement(user2);System.out.println(user2.getAge()); //13

  

  参考博文:

  http://ifeve.com/java-atomic/
  http://blog.csdn.net/qfycc92/article/details/46489553

转载于:https://www.cnblogs.com/hunterCecil/p/8459501.html

JDK源码学习之 java.util.concurrent.automic包相关推荐

  1. JDK源码解析之Java.util.Collections

    java.util.Collections 是一个包装类.它包含有各种有关集合操作的静态多态方法.此类不能实例化,就像一个工具类,服务于Java的Collection框架. 一.源码解析 1.不可实例 ...

  2. JDK源码解析之java.util.AbstractCollection

    AbstractCollection类提供了collection的实现类应该具有的基本方法,具有一定的普适性,可以从大局上了解collection实现类的主要功能. java.util.Abstrac ...

  3. JDK源码解析之Java.util.Collection

    Collection是单例集合的顶层接口,它表示一组对象,这些对象也称为Collection的元素,JDK 不提供此接口的任何直接实现,它提供更具体的子接口(如Set和List)实现 一.源码解析 1 ...

  4. JDK源码解析之java.util.Iterator和java.lang.Iterable

    在Java中,我们可以对List集合进行如下几种方式的遍历:第一种就是普通的for循环,第二种为迭代器遍历,第三种是for each循环.后面两种方式涉及到Java中的iterator和iterabl ...

  5. JDK源码解析之java.util.ListIterator

    ListIterator是一个功能更加强大的迭代器接口, 它继承于Iterator接口,只能用于各种List类型的访问.可以通过调用listIterator()方法产生一个指向List开始处的List ...

  6. JAVA JDK 源码学习

    JAVA JDK 源码学习 ,以1.8为例,按照下面图片顺序依次学习: applet ,awt,beans,io,lang,math,net,nio,rmi,security,sql,text,tim ...

  7. JDK源码学习-基础

    JDK源码学习 目录 基础 1. 安装 1.1 下载JDK 1.2 配置环境变量 1.3 验证 2. 简单的程序 2.1 编写代码 2.2 编译文件 2.3 执行类 3. java基本类型 基础 1. ...

  8. 【JDK源码】java.util.concurrent.atomic包常用类详解

    java.util.concurrent.atomic原子操作类包里面提供了一组原子变量类.其基本的特性就是在多线程环境下,当有多个线程同时执行这些类的实例包含的方法时,具有排他性,即当某个线程进入方 ...

  9. [Jdk源码学习]聊聊concurrent包下面的volite*

    引子:关于Java并发中的volatile关键字 并切--定义 悲观锁: 1.一个线程在执行一个操作时持有对一个资源的独占锁(A线程占了资源a,则其他线程就不能操作资源a) 2.一般用在冲突比较可能发 ...

  10. JDK源码学习路线~每天学一点~每天进步一点点

    很多java开发的小伙伴都会阅读jdk源码,然而确不知道应该从哪读起.以下为小编整理的通常所需阅读的源码范围. 标题为包名,后面序号为优先级1-4,优先级递减 1.java.lang 1) Objec ...

最新文章

  1. java数据库易错程序题_JAVA程序改错 (易错题)(示例代码)
  2. UNIX环境高级编程笔记
  3. java 死锁的检测与修复_调查死锁–第4部分:修复代码
  4. 最年轻图灵奖女性得主:谁说女的数学都比男的差
  5. VS2017安装配置Qt
  6. leetcode Longest Consecutive Sequence
  7. HackerOne 发布2021年《黑客驱动安全报告:行业洞察》
  8. Ubuntu源硬盘挂载到本地计算机更新源
  9. 4级网络工程师第5套知识点
  10. 【网络安全】jquery版本漏洞如何验证
  11. 品牌设计分析思维导图模板分享
  12. 基于Spark的公安大数据实时运维技术实践
  13. 如何判断一个点在三角形内部
  14. svchost.exe不停下载
  15. 商业插画是什么?怎么学习商业插画?
  16. Java文件解析:Excel解析
  17. contentprovider踩坑之路之Failed to find provider info for com.example.app.provider和cursor=null空指针问题
  18. 公众号运营技巧:大V的公众号都是怎么运营的?
  19. 已解决ValueError: More than 4094 XFs (styles)
  20. 【力扣题解】面试题 10.11. 峰与谷

热门文章

  1. 为什么h5上传服务器只显示图片,【Web前端问题】怎么把图片从前端上传到服务器?...
  2. linux复习题之阶段性考试题目
  3. 【收藏】基于Dockerfile搭建JAVA Tomcat运行环境
  4. Quartz-scheduler 定时器概述、核心 API 与 快速入门
  5. 阶段1 语言基础+高级_1-3-Java语言高级_06-File类与IO流_09 序列化流_4_transient关键字_瞬态关键字...
  6. [SDOI2010]代码拍卖会
  7. 130242014021-田富钊-实验一
  8. 《出发吧一起》第二阶段个人总结——Day08
  9. Hibernate(转载)
  10. VC++动态链接库编程之MFC规则DLL