24.Java中atomic包中的原子操作类总结

1. 原子操作类介绍

在并发编程中很容易出现并发安全的问题，有一个很简单的例子就是多线程更新变量i=1,比如多个线程执行i++操作，就有可能获取不到正确的值，而这个问题，最常用的方法是通过Synchronized进行控制来达到线程安全的目的（关于synchronized可以看这篇文章）。但是由于synchronized是采用的是悲观锁策略，并不是特别高效的一种解决方案。实际上，在J.U.C下的atomic包提供了一系列的操作简单，性能高效，并能保证线程安全的类去更新基本类型变量，数组元素，引用类型以及更新对象中的字段类型。atomic包下的这些类都是采用的是乐观锁策略去原子更新数据，在java中则是使用CAS操作具体实现。

2. 预备知识--CAS操作

能够弄懂atomic包下这些原子操作类的实现原理，就要先明白什么是CAS操作。

什么是CAS?

使用锁时，线程获取锁是一种悲观锁策略，即假设每一次执行临界区代码都会产生冲突，所以当前线程获取到锁的时候同时也会阻塞其他线程获取该锁。而CAS操作（又称为无锁操作）是一种乐观锁策略，它假设所有线程访问共享资源的时候不会出现冲突，既然不会出现冲突自然而然就不会阻塞其他线程的操作。因此，线程就不会出现阻塞停顿的状态。那么，如果出现冲突了怎么办？无锁操作是使用CAS(compare and swap)又叫做比较交换来鉴别线程是否出现冲突，出现冲突就重试当前操作直到没有冲突为止。

CAS的操作过程

CAS比较交换的过程可以通俗的理解为CAS(V,O,N)，包含三个值分别为：V 内存地址存放的实际值；O 预期的值（旧值）；N 更新的新值。当V和O相同时，也就是说旧值和内存中实际的值相同表明该值没有被其他线程更改过，即该旧值O就是目前来说最新的值了，自然而然可以将新值N赋值给V。反之，V和O不相同，表明该值已经被其他线程改过了则该旧值O不是最新版本的值了，所以不能将新值N赋给V，返回V即可。当多个线程使用CAS操作一个变量是，只有一个线程会成功，并成功更新，其余会失败。失败的线程会重新尝试，当然也可以选择挂起线程

CAS的实现需要硬件指令集的支撑，在JDK1.5后虚拟机才可以使用处理器提供的CMPXCHG指令实现。

Synchronized VS CAS

元老级的Synchronized(未优化前)最主要的问题是：在存在线程竞争的情况下会出现线程阻塞和唤醒锁带来的性能问题，因为这是一种互斥同步（阻塞同步）。而CAS并不是武断的间线程挂起，当CAS操作失败后会进行一定的尝试，而非进行耗时的挂起唤醒的操作，因此也叫做非阻塞同步。这是两者主要的区别。

CAS的问题

  1. ABA问题
    因为CAS会检查旧值有没有变化，这里存在这样一个有意思的问题。比如一个旧值A变为了成B，然后再变成A，刚好在做CAS时检查发现旧值并没有变化依然为A，但是实际上的确发生了变化。解决方案可以沿袭数据库中常用的乐观锁方式，添加一个版本号可以解决。原来的变化路径A->B->A就变成了1A->2B->3C。
  2. 自旋时间过长

使用CAS时非阻塞同步，也就是说不会将线程挂起，会自旋（无非就是一个死循环）进行下一次尝试，如果这里自旋时间过长对性能是很大的消耗。如果JVM能支持处理器提供的pause指令，那么在效率上会有一定的提升。

3. 原子更新基本类型

atomic包提高原子更新基本类型的工具类，主要有这些：

  1. AtomicBoolean：以原子更新的方式更新boolean；
  2. AtomicInteger：以原子更新的方式更新Integer;
  3. AtomicLong：以原子更新的方式更新Long；

这几个类的用法基本一致，这里以AtomicInteger为例总结常用的方法

  1. addAndGet(int delta) ：以原子方式将输入的数值与实例中原本的值相加，并返回最后的结果；
  2. incrementAndGet() ：以原子的方式将实例中的原值进行加1操作，并返回最终相加后的结果；
  3. getAndSet(int newValue)：将实例中的值更新为新值，并返回旧值；
  4. getAndIncrement()：以原子的方式将实例中的原值加1，返回的是自增前的旧值；

还有一些方法，可以查看API，不再赘述。为了能够弄懂AtomicInteger的实现原理，以getAndIncrement方法为例，来看下源码：

public final int getAndIncrement() {    return unsafe.getAndAddInt(this, valueOffset, 1);}

可以看出，该方法实际上是调用了unsafe实例的getAndAddInt方法，unsafe实例的获取时通过UnSafe类的静态方法getUnsafe获取：

private static final Unsafe unsafe = Unsafe.getUnsafe();

Unsafe类在sun.misc包下，Unsafer类提供了一些底层操作，atomic包下的原子操作类的也主要是通过Unsafe类提供的compareAndSwapInt，compareAndSwapLong等一系列提供CAS操作的方法来进行实现。下面用一个简单的例子来说明AtomicInteger的用法：

public class AtomicDemo {    private static AtomicInteger atomicInteger = new AtomicInteger(1);?    public static void main(String[] args) {        System.out.println(atomicInteger.getAndIncrement());        System.out.println(atomicInteger.get());    }}输出结果：12

例子很简单，就是新建了一个atomicInteger对象，而atomicInteger的构造方法也就是传入一个基本类型数据即可，对其进行了封装。对基本变量的操作比如自增，自减，相加，更新等操作，atomicInteger也提供了相应的方法进行这些操作。但是，因为atomicInteger借助了UnSafe提供的CAS操作能够保证数据更新的时候是线程安全的，并且由于CAS是采用乐观锁策略，因此，这种数据更新的方法也具有高效性。

AtomicLong的实现原理和AtomicInteger一致，只不过一个针对的是long变量，一个针对的是int变量。而boolean变量的更新类AtomicBoolean类是怎样实现更新的呢?核心方法是compareAndSett方法，其源码如下：

public final boolean compareAndSet(boolean expect, boolean update) {    int e = expect ? 1 : 0;    int u = update ? 1 : 0;    return unsafe.compareAndSwapInt(this, valueOffset, e, u);}

可以看出，compareAndSet方法的实际上也是先转换成0,1的整型变量，然后是通过针对int型变量的原子更新方法compareAndSwapInt来实现的。可以看出atomic包中只提供了对boolean,int ,long这三种基本类型的原子更新的方法，参考对boolean更新的方式，原子更新char,doule,float也可以采用类似的思路进行实现。

4. 原子更新数组类型

atomic包下提供能原子更新数组中元素的类有：

  1. AtomicIntegerArray：原子更新整型数组中的元素；
  2. AtomicLongArray：原子更新长整型数组中的元素；
  3. AtomicReferenceArray：原子更新引用类型数组中的元素

这几个类的用法一致，就以AtomicIntegerArray来总结下常用的方法：

  1. addAndGet(int i, int delta)：以原子更新的方式将数组中索引为i的元素与输入值相加；
  2. getAndIncrement(int i)：以原子更新的方式将数组中索引为i的元素自增加1；
  3. compareAndSet(int i, int expect, int update)：将数组中索引为i的位置的元素进行更新

可以看出，AtomicIntegerArray与AtomicInteger的方法基本一致，只不过在AtomicIntegerArray的方法中会多一个指定数组索引位i。下面举一个简单的例子：

public class AtomicDemo {    //    private static AtomicInteger atomicInteger = new AtomicInteger(1);    private static int[] value = new int[]{1, 2, 3};    private static AtomicIntegerArray integerArray = new AtomicIntegerArray(value);?    public static void main(String[] args) {        //对数组中索引为1的位置的元素加5        int result = integerArray.getAndAdd(1, 5);        System.out.println(integerArray.get(1));        System.out.println(result);    }}输出结果：72

通过getAndAdd方法将位置为1的元素加5，从结果可以看出索引为1的元素变成了7，该方法返回的也是相加之前的数为2。

5. 原子更新引用类型

如果需要原子更新引用类型变量的话，为了保证线程安全，atomic也提供了相关的类：

  1. AtomicReference：原子更新引用类型；
  2. AtomicReferenceFieldUpdater：原子更新引用类型里的字段；
  3. AtomicMarkableReference：原子更新带有标记位的引用类型；

这几个类的使用方法也是基本一样的，以AtomicReference为例，来说明这些类的基本用法。下面是一个demo

public class AtomicDemo {?    private static AtomicReference<User> reference = new AtomicReference<>();?    public static void main(String[] args) {        User user1 = new User("a", 1);        reference.set(user1);        User user2 = new User("b",2);        User user = reference.getAndSet(user2);        System.out.println(user);        System.out.println(reference.get());    }?    static class User {        private String userName;        private int age;?        public User(String userName, int age) {            this.userName = userName;            this.age = age;        }?        @Override        public String toString() {            return "User{" +                    "userName=‘" + userName + ‘\‘‘ +                    ", age=" + age +                    ‘}‘;        }    }}?输出结果：User{userName=‘a‘, age=1}User{userName=‘b‘, age=2}

首先将对象User1用AtomicReference进行封装，然后调用getAndSet方法，从结果可以看出，该方法会原子更新引用的user对象，变为User{userName=‘b‘, age=2}，返回的是原来的user对象User{userName=‘a‘, age=1}。

6. 原子更新字段类型

如果需要更新对象的某个字段，并在多线程的情况下，能够保证线程安全，atomic同样也提供了相应的原子操作类：

  1. AtomicIntegeFieldUpdater：原子更新整型字段类；
  2. AtomicLongFieldUpdater：原子更新长整型字段类；
  3. AtomicStampedReference：原子更新引用类型，这种更新方式会带有版本号。而为什么在更新的时候会带有版本号，是为了解决CAS的ABA问题；

要想使用原子更新字段需要两步操作：

  1. 原子更新字段类都是抽象类，只能通过静态方法newUpdater来创建一个更新器，并且需要设置想要更新的类和属性；
  2. 更新类的属性必须使用public volatile进行修饰；

这几个类提供的方法基本一致，以AtomicIntegerFieldUpdater为例来看看具体的使用：

public class AtomicDemo {?    private static AtomicIntegerFieldUpdater updater = AtomicIntegerFieldUpdater.newUpdater(User.class,"age");    public static void main(String[] args) {        User user = new User("a", 1);        int oldValue = updater.getAndAdd(user, 5);        System.out.println(oldValue);        System.out.println(updater.get(user));    }?    static class User {        private String userName;        public volatile int age;?        public User(String userName, int age) {            this.userName = userName;            this.age = age;        }?        @Override        public String toString() {            return "User{" +                    "userName=‘" + userName + ‘\‘‘ +                    ", age=" + age +                    ‘}‘;        }    }} ?输出结果：16

从示例中可以看出，创建AtomicIntegerFieldUpdater是通过它提供的静态方法进行创建，getAndAdd方法会将指定的字段加上输入的值，并且返回相加之前的值。user对象中age字段原值为1，加5之后，可以看出user对象中的age字段的值已经变成了6。

原文地址：https://www.cnblogs.com/itxiaok/p/10356602.html

时间： 2024-11-07 20:10:58

24.Java中atomic包中的原子操作类总结的相关文章

Java中Atomic包的实现原理及应用

同步问题的提出         假设我们使用一个双核处理器执行A和B两个线程,核1执行A线程,而核2执行B线程,这两个线程现在都要对名为obj的对象的成员变量i进行加1操作,假设i的初始值为0,理论上两个线程运行后i的值应该变成2,但实际上很有可能结果为1.          我们现在来分析原因,这里为了分析的简单,我们不考虑缓存的情况,实际上有缓存会使结果为1的可能性增大.A线程将内存中的变量i读取到核1算数运算单元中,然后进行加1操作,再将这个计算结果写回到内存中,因为上述操作不是原子操作,

（转）java 从jar包中读取资源文件

(转)java 从jar包中读取资源文件 博客分类: java 源自:http://blog.csdn.net/b_h_l/article/details/7767829 在代码中读取一些资源文件(比如图片,音乐,文本等等),在集成环境(Eclipse)中运行的时候没有问题.但当打包成一个可执行的jar包(将资源文件一并打包)以后,这些资源文件找不到,如下代码:Java代码 [java] view plaincopy //源代码1: package edu.hxraid; import java

java 从jar包中读取资源文件

在代码中读取一些资源文件(比如图片,音乐,文本等等),在集成环境(Eclipse)中运行的时候没有问题.但当打包成一个可执行的jar包(将资源文件一并打包)以后,这些资源文件找不到,如下代码:Java代码 [java] view plaincopy //源代码1: package edu.hxraid; import java.io.*; public class Resource { public  void getResource() throws IOException{ File fil

JAVA问题解决——Jar包中资源调用

我在打包工程的时候,遇到在IDE中能够运行但jar包运行错误的情况(FileNotFoundException). 在网上找的很多解决方法都是需要使用getResouce方法获取绝对路径,或者必须先把文件读入才能继续操作. 使用getRescource仍然有上述错误:而要读取的文件是一个需要和前端交互,要在文件上进行操作的文件,必须保证文件原格式不变.所以读入再操作的方法并不适合,因为再输出时格式控制等会十分麻烦. 下面是一些解决问题中学习到的内容: i. jar包是一个文件,我的理解是,jar

java 遍历指定包名下所有的类(支持jar)

package com.shdl.htscada.utils; import java.io.File; import java.io.IOException; import java.io.UnsupportedEncodingException; import java.net.JarURLConnection; import java.net.URL; import java.net.URLClassLoader; import java.util.Enumeration; import 

java 执行 jar 包中的 main 方法

通过 OneJar 或 Maven 打包后 jar 文件,用命令:java -jar ****.jar执行后总是运行指定的主方法,如果 jar 中有多个 main 方法,那么如何运行指定的 main 方法呢?用下面的命令试试看: java -classpath ****.jar ****.****.className [args] “****.****”表示“包名”:“className”表示“类名”:“[args]”表示传入的参数: 直接运行 MANIFEST.MF 中指定的 main 方法:

java的NIO包中ByteBuffer类的clear(),flip(),rewind()方法的意思

我们要澄清一点:这三个方法都是ByteBuffer的抽象基类Buffer定义的方法,ByteBuffer只是继承了它们. **************************************************** 其次,你要理解缓冲区的概念,就是Buffer的意义:缓冲区是特定基本类型元素的线性有限序列.除内容外,缓冲区的基本属性还包括容量.限制和位置: 缓冲区的容量 是它所包含的元素的数量.缓冲区的容量不能为负并且不能更改. 缓冲区的限制 是第一个不应该读取或写入的元素的索引.缓

Python中导入包中模块的方法及区别

如果我们要使用一个package中定义的一个module,有两种导入方式 方法1: from package import module 方法2: import package import package.module 这两种方法的区别是通过方法1导入后,程序中可以直接使用module短命,而通过方法2导入后,程序中必须使用完整名称,即通过package.module使用,如果只导入package而不导入module,那么只有package中定义的__init__.py模块中的内容可用(使用该

【多线程与并发】Java中的12个原子操作类

从JDK1.5开始,Java提供了java.util.concurrent.atomic包,该包中的原子操作类提供了一种使用简单.性能高效(使用CAS操作,无需加锁).线程安全地更新一个变量的方式. `java.util.concurrent.atomic`包中的类.png 根据变量类型的不同,Atomic包中的这12个原子操作类可以分为4种类型: ①原子更新基本类型:AtomicBoolean.AtomicInteger.AtomicLong ②原子更新数组:AtomicIntegerArra