登录 注册

CAS 与 Auomic 原子类

本贴最后更新于 1640 天前，其中的信息可能已经事过境迁

CAS 与 Auomic 原子类

什么是原子操作？

"原子操作(atomic operation)是不需要 synchronized"，这是多线程编程的老生常谈了。所谓原子操作是指不会被线程调度机制打断的操作；这种操作一旦开始，就一直运行到结束，中间不会有任何 context switch （切换到另一个线程）。

Java 如何实现原子操作？

  1. 用锁，synchronized 内置锁、显示锁
  2. CAS 实现

synchronized 的缺点

  1. 在多线程竞争下，加锁、释放锁会导致比较多的上下文切换和调度延时，非常消耗资源，同时也可能带来死锁或者其它安全问题。
  2. 一个线程持有的锁很长时间不释放。
  3. 如果一个优先级高的线程等待一个优先级低的线程释放锁会导致优先级倒置，优先级高的反而不能得到执行，产生性能问题。

什么是 CAS？

在计算机科学中，比较和交换（Conmpare And Swap）是用于实现多线程同步的原子指令。 它将内存位置的内容与给定值进行比较，只有在相同的情况下，将该内存位置的内容修改为新的给定值。 这是作为单个原子操作完成的。 原子性保证新值基于最新信息计算; 如果该值在同一时间被另一个线程更新，则写入将失败。 操作结果必须说明是否进行替换; 这可以通过一个简单的布尔响应（这个变体通常称为比较和设置），或通过返回从内存位置读取的值来完成。

一个 CAS 涉及到以下操作：

我们假设内存中的原数据 V，旧的预期值 A，需要修改的新值 B。

  1. 比较 A 与 V 是否相等。（比较）
  2. 如果比较相等，将 B 写入 V。（交换）
  3. 返回操作是否成功。
CAS 自旋

基于 CAS 的自旋就是典型的乐观锁，程序执行时，某个线程从共享内存中取值 V 并建一个副本 A，对 A 进行计算后将新的值保存为 B，然后对 A 值和内存中的 V 值进行比较，如果 A 等于 V，则认为内存中的 V 值没有被其他线程修改过，可以将新值 B 赋给内存中的 V，否则，认为内存中已被其他的线程修改，则重新执行上述计算步骤，即 ！！！ 先从内存中取得 V 的副本 A，对 A 进行计算完成后将结果保存为 B，再将 A 与内存中的 V 进行比较，如果不相同则继续循环跳到 ！！！ 处，直到线程本地副本 A 值等于内存值 V 为止。

CAS 的缺点
  1. ABA 问题。因为 CAS 需要在操作值的时候检查下值有没有发生变化，如果没有发生变化则更新，但是如果一个值原来是 A，变成了 B，又变成了 A，那么使用 CAS 进行检查时会发现它的值没有发生变化，但是实际上却变化了。ABA 问题的解决思路就是使用版本号。Java 现在提供了带有版本号的 Atomic 类。
  2. 循环时间长开销大。自旋 CAS 如果长时间不成功，会给 CPU 带来非常大的执行开销。
  3. 只能保证一个共享变量的原子操作。

Java 中采用 CAS 原理实现的原子类有哪些？

基本类型

使用原子的方式更新基本类型

  • AtomicInteger：整形原子类
  • AtomicLong：长整型原子类
  • AtomicBoolean：布尔型原子类
数组类型

使用原子的方式更新数组里的某个元素

  • AtomicIntegerArray：整形数组原子类
  • AtomicLongArray：长整形数组原子类
  • AtomicReferenceArray：引用类型数组原子类
引用类型
  • AtomicReference：引用类型原子类
  • AtomicStampedReference：原子更新带有版本号的引用类型。该类将整数值与引用关联起来，可用于解决原子的更新数据和数据的版本号，可以解决使用 CAS 进行原子更新时可能出现的 ABA 问题。
  • AtomicMarkableReference ：原子更新带有标记位的引用类型，传入 Boolean 值，表示是否改动过，为了解决可能出现的 ABA 问题
字段类型
  • AtomicIntegerFieldUpdater：原子更新整形字段的更新器
  • AtomicLongFieldUpdater：原子更新长整形字段的更新器
  • AtomicReferenceFieldUpdater： 原子更新引用类型字段的更新器。

AtomicInteger

AtomicInteger 的常用方法
  • int get() //获取当前的值
  • int getAndSet(int newValue)//获取当前的值，并设置新的值
  • int getAndIncrement()//获取当前的值，并自增，i++
  • int getAndDecrement() //获取当前的值，并自减, i--
  • int incrementAndGet() //先自增，然后获取自增后的值, ++i
  • int getAndAdd(int delta) //获取当前的值，并加上预期的值
  • boolean compareAndSet(int expect, int update) //如果输入的数值等于预期值，则以原子方式将该值设置为输入值（update）
  • void lazySet(int newValue)//最终设置为 newValue,使用 lazySet 设置之后可能导致其他线程在之后的一小段时间内还是可以读到旧的值。
使用实例
	static AtomicInteger atomicInteger = new AtomicInteger(10);

    public static void main(String[] args) {
    	System.out.println(atomicInteger.getAndIncrement());//先获取值，再自增
    	System.out.println(atomicInteger.incrementAndGet());//先自增，再获取值
    	System.out.println(atomicInteger.get());
    }

大家可以自己测试一下上述程序的输出。
下面我们多启动几个线程，来测试一下 Atomic 类的原子性。

    static AtomicInteger atomicInteger = new AtomicInteger(10);

    private static class TestAtomicInteger extends Thread{
        private AtomicInteger atomicInteger;
        TestAtomicInteger(AtomicInteger atomicInteger){
            this.atomicInteger = atomicInteger;
        }
        @Override
        public void run() {
            Random random = new Random();
            try {
                Thread.sleep(random.nextInt(1000));//让每个线程休眠不同的时间
                int andIncrement = atomicInteger.getAndIncrement();
                System.out.println(Thread.currentThread().getId() +"号线程的值为：" +  andIncrement);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    public static void main(String[] args) {
        for (int i=0; i<30; i++){//启动三十个线程
            new TestAtomicInteger(atomicInteger).start();
        }
    }

我们启动了三十个线程，并让不同的线程休眠了不同的时间，我们来看一下输出。

33号线程的值为：11//第一次运行的时候出现了这种情况。
26号线程的值为：10//只能说这个33号线程太争气了。。。
15号线程的值为：12
25号线程的值为：13
13号线程的值为：14
21号线程的值为：15
37号线程的值为：16
18号线程的值为：17
24号线程的值为：18
30号线程的值为：19
16号线程的值为：20
31号线程的值为：21
39号线程的值为：22
22号线程的值为：23
28号线程的值为：24
....

我们可以看到，并没有产生任何的数据冲突。

AtomicInteger 原理

AtomicInteger 类的部分源码

    // setup to use Unsafe.compareAndSwapInt for updates
    private static final Unsafe unsafe = Unsafe.getUnsafe();
    private static final long valueOffset;

    static {
        try {
            valueOffset = unsafe.objectFieldOffset
                (AtomicInteger.class.getDeclaredField("value"));
        } catch (Exception ex) { throw new Error(ex); }
    }

    private volatile int value;

AtomicInteger 类主要利用 CAS (compare and swap) + volatile 和 native 方法来保证原子操作，从而避免 synchronized 的高开销，执行效率大为提升。
CAS 的原理是拿期望的值和原本的一个值作比较，如果相同则更新成新的值。UnSafe 类的 objectFieldOffset() 方法是一个本地方法，这个方法是用来拿到“原来的值”的内存地址，返回值是 valueOffset。另外 value 是一个 volatile 变量，在内存中可见，因此 JVM 可以保证任何时刻任何线程总能拿到该变量的最新值。

其它的 Atomic 类

AtomicArray 的简单使用
    static int[] value = new int[] { 1, 2 };
    static AtomicIntegerArray atomicIntegerArray= new AtomicIntegerArray(value);
    public static void main(String[] args) {
    	atomicIntegerArray.getAndSet(0, 3);//第一个参数为数组的下标，第二个参数为要赋予的新值
    	System.out.println(atomicIntegerArray.get(0));//获取下标为0的值
    	System.out.println(value[0]);//只改变了对象的引用，原对象的值是不变的
    }
AtomicReference 的简单使用
	static AtomicReference<UserInfo> atomicReference = new AtomicReference<UserInfo>();
    public static void main(String[] args) {
        UserInfo user = new UserInfo("Mark", 15);//要修改的实体的实例
        atomicReference.set(user);

        UserInfo updateUser = new UserInfo("Bill", 17);//要变化的新实例
        atomicReference.compareAndSet(user, updateUser);//先比较，再赋值
        System.out.println(atomicReference.get().getName());
        System.out.println(atomicReference.get().getAge());
        System.out.println(user.getName());//改变的是对象的引用而不是对象本身
        System.out.println(user.getAge());
    }

    //定义一个实体类
    static class UserInfo {
        private String name;
        private int age;
        public UserInfo(String name, int age) {
            this.name = name;
            this.age = age;
        }
        public String getName() {
            return name;
        }
        public int getAge() {
            return age;
        }
    }
UseAtomicStampedReference 的简单使用
  • AtomicStampedReference：原子更新带有版本号的引用类型。该类将整数值与引用关联起来，可用于解决原子的更新数据和数据的版本号，可以解决使用 CAS 进行原子更新时可能出现的 ABA 问题。

public AtomicStampedReference(V initialRef, int initialStamp) { pair = Pair.of(initialRef, initialStamp); }
以上为 UseAtomicStampedReference 的构造方法，创建实例对象时，需将引用以及对应的初始版本号传入。

该类的 api 有

  1. V getReference()
  2. int getStamp() 获取版本号
  3. public boolean compareAndSet(V expectedReference, V newReference, int expectedStamp, int newStamp) 如果当前引用 等于 预期值并且 当前版本戳等于预期版本戳, 将更新新的引用和新的版本戳到内存
  4. boolean attemptStamp(V expectedReference, int newStamp) 如果当前引用 等于 预期引用, 将更新新的版本戳到内存
  5. void set(V newReference, int newStamp) 设置当前引用的新引用和版本戳
	static AtomicStampedReference<String> stampedReference =
			new AtomicStampedReference<>("Test",0); //初始值，跟初始化的版本号

    public static void main(String[] args) throws InterruptedException {
    	final int oldStamp = stampedReference.getStamp();//获取初始的版本号
    	final String oldReferenc = stampedReference.getReference();//获取原来的值
    	System.out.println("原值为：" + oldReferenc+"    版本号为： "+oldStamp);

    	Thread rightStampThread = new Thread(() -> System.out.println(Thread.currentThread().getId()
				+"当前变量值："+oldReferenc+"当前版本戳："+oldStamp
				+" 赋值是否成功： " + stampedReference.compareAndSet(oldReferenc, oldReferenc+"Java",
						oldStamp, oldStamp+1)));

    	Thread errorStampThread = new Thread(() -> {
			String reference = stampedReference.getReference();
			System.out.println(Thread.currentThread().getId()
					+"当前变量值："+reference+"当前版本戳："+ stampedReference.getStamp()
					+" 赋值是否成功： " + stampedReference.compareAndSet(reference, reference+"C",
							oldStamp, oldStamp+1));

		});

    	rightStampThread.start();
    	rightStampThread.join();// 等待线程结束
    	errorStampThread.start();
    	errorStampThread.join();
    	System.out.println("原值为：" + stampedReference.getReference()+"    版本号为： "+stampedReference.getStamp());
    }

输出如下：

原值为：Test    版本号为： 0
12当前变量值：Test当前版本戳：0 赋值是否成功： true
13当前变量值：TestJava当前版本戳：1 赋值是否成功： false
原值为：TestJava    版本号为： 1

参考自：
JAVA 中的 CAS ： https://juejin.im/post/5a75db20f265da4e826320a9
CAS 自旋： https://blog.csdn.net/sinat_28028941/article/details/53539775
JAVA CAS 实现原理与使用： https://blog.csdn.net/u011506543/article/details/82392338
JavaGuide： https://snailclimb.top/JavaGuide/#/?id=%e5%b9%b6%e5%8f%91

  • Java

    Java 是一种可以撰写跨平台应用软件的面向对象的程序设计语言，是由 Sun Microsystems 公司于 1995 年 5 月推出的。Java 技术具有卓越的通用性、高效性、平台移植性和安全性。

    3167 引用 • 8207 回帖 • 1 关注
  • 基础知识
    13 引用 • 6 回帖
  • 并发
    75 引用 • 73 回帖 • 1 关注
烟台 位置
2 回帖
636 20 116 44 138 32 1 44 231

相关帖子

2 回帖
CAS 与 Auomic 原子类

欢迎来到这里！

我们正在构建一个小众社区，大家在这里相互信任，以平等 • 自由 • 奔放的价值观进行分享交流。最终，希望大家能够找到与自己志同道合的伙伴，共同成长。

注册 关于
请输入回帖内容 ...
  • valarchie •
    捐赠者

    好多错别字....😂

  • someone •
    作者

    嘿嘿，有错别字的地方提醒我一下 。
    我自己不太好找 ❤️

DongXiaokai0819
烟台
回帖
5
 帖子
23
 积分
489