19、深入理解CAS
什么是CAS
package com.xing.cas;
import java.util.concurrent.atomic.AtomicInteger;
// 原子类的底层用的cas
public class CASDemo {
//compareAndSet比较并交换
public static void main(String[] args) {
AtomicInteger atomicInteger = new AtomicInteger(2020);//原子类
/*
期望 更新
public final boolean compareAndSet(int expect, int update) {
return unsafe.compareAndSwapInt(this, valueOffset, expect, update);
}
*/
//如果和期望的值相同就更新，CAS是CPU的并发原语
System.out.println(atomicInteger.compareAndSet(2020, 2021));
System.out.println(atomicInteger.get()); // 2021
// 上面已经修改为了2021 所以这个失败
System.out.println(atomicInteger.compareAndSet(2020, 20201));
System.out.println(atomicInteger.get());//2021
}
}
AtomicInteger的getAndIncrement方法源码
unsafe类
精髓！！！！：var1对象等于var2内存地址偏移值，对应如果这个值还是我们希望的var5，那么我们就让这个值加一
总结：CAS： 比较当前工作内存中的值，若果这个值是期望中的，那么执行该操作 ，如果不是会一直循环因为底层是do while会一直循环
缺点：
-
循环耗时
-
一次性只能保证一个共享变量的共享性
-
ABA问题
ABA问题（狸猫换太子）别人改了又改回去,但是使用的人不知道
package com.xing.cas;
import java.util.concurrent.atomic.AtomicInteger;
public class CASDemo {
//比较并交换
public static void main(String[] args) {
AtomicInteger atomicInteger = new AtomicInteger(2020);//原子类
/*
期望 更新
public final boolean compareAndSet(int expect, int update) {
return unsafe.compareAndSwapInt(this, valueOffset, expect, update);
}
*/
//对我们写平时写的sql:乐观锁
//如果和期望的值相同就更新，CAS是CPU的并发原语
//*******捣乱的线程**********
System.out.println(atomicInteger.compareAndSet(2020, 2021));
System.out.println(atomicInteger.get()); // 2021
System.out.println(atomicInteger.compareAndSet(2021, 2020));
System.out.println(atomicInteger.get()); // 2020
//********期望的线程*********
System.out.println(atomicInteger.compareAndSet(2020, 2021));
System.out.println(atomicInteger.get());//2021
}
}
虽然最终期望确实完成可但是我们不希望数据被人动过了还不知道下面来解决这个问题
如何解决这个问题？原子引用
我们使用另外一个 AtomicStampedReference 原子类 带有版本号时间戳，可以每次记录加一类似于乐观锁
20、原子引用（解决CAS的ABA问题）
带版本号的原子操作
package com.xing.cas;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicStampedReference;
public class CASDemo {
//比较并交换
public static void main(String[] args) {
//注意，如果泛型是一个包装类，注意对象的引用问题 正常业务中,泛型中都是对象
//Integer 使用了对象缓存机制，默认范围是 -128 ~ 127 ，推荐使用静态工厂方法 valueOf 获取对象实例，而不是 new，因为 valueOf 使用缓存，而 new 一定会创建新的对象分配新的内存空间；
AtomicStampedReference<Integer> atomicInteger = new AtomicStampedReference<>(1,1);//初始值，版本号时间戳
new Thread(()->{
int stamp = atomicInteger.getStamp();//获得版本号
System.out.println("A = >" + stamp);
try {
TimeUnit.SECONDS.sleep(2);
} catch (InterruptedException e) {
e.printStackTrace();
}
//最后两个参数，拿到最新的版本号，把版本号+1 期望值 更新值 期望时间戳 新时间戳
System.out.println(atomicInteger.compareAndSet(1, 2, atomicInteger.getStamp(), atomicInteger.getStamp() + 1));
System.out.println("A2 = >"+atomicInteger.getStamp());
//把这个值该回去
System.out.println(atomicInteger.compareAndSet(2, 1, atomicInteger.getStamp(), atomicInteger.getStamp() + 1));
System.out.println("A3 = >"+atomicInteger.getStamp());
},"a").start();
new Thread(()->{
int stamp = atomicInteger.getStamp();//获得版本号
System.out.println("B = >" + stamp);
try {
TimeUnit.SECONDS.sleep(2);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(atomicInteger.compareAndSet(1, 3, stamp, stamp + 1));
System.out.println("b2 = >" +atomicInteger.getStamp());
},"b").start();
}
}
注意：Integer 使用了对象缓存机制，默认范围是 -128 ~ 127 ，推荐使用静态工厂方法 valueOf 获取对象实例，而不是 new，因为 valueOf 使用缓存，而 new 一定会创建新的对象分配新的内存空间；每一次的2020都是一个新的值
阿里巴巴手册
