Java并发多线程编程——CAS

示例代码

import java.util.concurrent.atomic.AtomicInteger;
/**
 * @description:
 * @author: xz
 */
public class CASDemo {
    public static void main(String[] args) {

        //声明一个原子类，初始值为5，即主内存中的值为5
        AtomicInteger atomicInteger = new AtomicInteger(5);

        //当线程Thread-0中的期望值和主内存中的值5相同，修改为更新的值2022
        new Thread(()->{
            System.out.println("线程"+Thread.currentThread().getName()+"\t"+
                    atomicInteger.compareAndSet(5, 2022)+"\t current value："+atomicInteger.get());
        }).start();

        //当线程Thread-1中的期望值和主内存中的值5相同，修改为更新的值2000
        new Thread(()->{
            System.out.println("线程"+Thread.currentThread().getName()+"\t"+
                    atomicInteger.compareAndSet(5, 2000)+"\t current value："+atomicInteger.get());
        }).start();

    }
}

输出结果

【总结】

线程Thread-0中的期望值5和主内存中的值5相同，返回true，将期望值5修改为更新的值2022并刷新会主内存中。

由于线程Thread-0已经把主内存中的值修改为了2022，所以当线程Thread-1中的期望值5和主内存中的值2022不相同，返回false，将期望值5修改为更新的值2000失败，返回的还是线程Thread-0中修改后的值2022。

即真实值和期望值相同，修改成功；真实值和期望值不相同，修改失败。

AtomicInteger原子类中valueOffset和value变量图解，如下图： （1）、变量ValueOffset：指该变量在内存中的偏移地址,因为UnSafe就是根据内存偏移地址获取数据的> （2）、变量value：该变量用volatile修饰,保证了多线程之间的可见性。

AtomicInteger原子类中getAndIncrement()方法源码，如下图：

Unsafe类中getAndIncrement()方法源码，如下图：

【上图解释】

var1：表示AtomicInteger对象本身。

var2：表示该对象值的引用地址。

var4：表示需要变动的数值。

var5：表示用var1、var2找出内存中真实的值。

用该对象当前的值与var5比较。如果相同,更新var5的值并且返回true。如果不同，继续取值然后比较,直到更新完成

循环时间长开销很大。

只能保证一个共享变量的原子性。

引起ABA问题。