高并发之CAS机制和ABA问题

什么是CAS机制

CAS是英文单词Compare and Swap的缩写，翻译过来就是比较并替换

CAS机制中使用了3个基本操作数：内存地址V，旧的预期值A，要修改的新值B。

看如下几个例子：

package com.example.demo.concurrentDemo;import org.junit.Test;import java.util.concurrent.atomic.AtomicInteger;public class CasTest {private static int count = 0;@Testpublic void test1(){for (int j = 0; j < 2; j++) {new Thread(() -> {for (int i = 0; i < 10000; i++) {count++;}}).start();}try {Thread.sleep(5000);} catch (InterruptedException e) {e.printStackTrace();}//结果必定 count <= 20000 System.out.println(count);}@Testpublic void test2() {for (int j = 0; j < 2; j++) {new Thread(() -> {for (int i = 0; i < 10000; i++) {synchronized (this) {count++;}}}).start();}try {Thread.sleep(5000);} catch (InterruptedException e) {e.printStackTrace();}//synchronized 类似于悲观锁//synchronized关键字会让没有得到锁资源的线程进入BLOCKED状态，而后在争夺到锁资源后恢复为RUNNABLE状态//这个过程中涉及到操作系统用户模式和内核模式的转换，代价比较高 System.out.println(count);}private static AtomicInteger atoCount = new AtomicInteger(0);@Testpublic void test3() {for (int j = 0; j < 2; j++) {new Thread(() -> {for (int i = 0; i < 10000; i++) {atoCount.incrementAndGet();}}).start();}try {Thread.sleep(5000);} catch (InterruptedException e) {e.printStackTrace();}//Atomic操作类的底层正是用到了“CAS机制” System.out.println(atoCount);}}

CAS 缺点

1） CPU开销过大

在并发量比较高的情况下，如果许多线程反复尝试更新某一个变量，却又一直更新不成功，循环往复，会给CPU带来很到的压力。

这个可以通过看：AtomicInteger.incrementAndGet()源码，可知这是一个无限循环，获取实际值与预期值比较，当相等才会跳出循坏。

2） 不能保证代码块的原子性

CAS机制所保证的知识一个变量的原子性操作，而不能保证整个代码块的原子性。比如需要保证3个变量共同进行原子性的更新，就不得不使用synchronized了。

3） ABA问题

这是CAS机制最大的问题所在。

 

什么是ABA?先看下面例子：

我们先来看一个多线程的运行场景：
时间点1 ：线程1查询值是否为A 
时间点2 ：线程2查询值是否为A 
时间点3 ：线程2比较并更新值为B 
时间点4 ：线程2查询值是否为B 
时间点5 ：线程2比较并更新值为A 
时间点6 ：线程1比较并更新值为C

在这个线程执行场景中，2个线程交替执行。线程1在时间点6的时候依然能够正常的进行CAS操作，尽管在时间点2到时间点6期间已经发生一些意想不到的变化， 但是线程1对这些变化却一无所知，因为对线程1来说A的确还在。通常将这类现象称为ABA问题。
ABA发生了，但线程不知道。又或者链表的头在变化了两次后恢复了原值，但是不代表链表就没有变化。

ABA隐患

就像兵法讲的：偷梁换柱、李代桃僵 

历史事件：赵氏孤儿

 解决ABA问题两种方法：

1、悲观锁思路，加锁；

2、乐观锁思路，通过AtomicStampedReference.class 

源码实现，具体看源码：

1. 创建一个Pair类来记录对象引用和时间戳信息,采用int作为时间戳，实际使用的时候时间戳信息要做成自增的，否则时间戳如果重复，还会出现ABA的问题。这个Pair对象是不可变对象，所有的属性都是final的， of方法每次返回一个新的不可变对象。

2. 使用一个volatile类型的引用指向当前的Pair对象，一旦volatile引用发生变化，变化对所有线程可见。

3. set方法时，当要设置的对象和当前Pair对象不一样时，新建一个不可变的Pair对象。

4. compareAndSet方法中，只有期望对象的引用和版本号和目标对象的引用和版本好都一样时，才会新建一个Pair对象，然后用新建的Pair对象和原理的Pair对象做CAS操作。

5. 实际的CAS操作比较的是当前的pair对象和新建的pair对象，pair对象封装了引用和时间戳信息。

Demo:

 

@Testpublic void test4() {final int timeStamp = atoReferenceCount.getStamp();new Thread(() -> {while(true){if(atoReferenceCount.compareAndSet(atoReferenceCount.getReference(),atoReferenceCount.getReference()+1, timeStamp, timeStamp + 1)){System.out.println("11111111");break;}}},"线程1：").start();new Thread(() -> {while(true){if(atoReferenceCount.compareAndSet(atoReferenceCount.getReference(),atoReferenceCount.getReference()+1, timeStamp, timeStamp + 1)){System.out.println("2222222");break;}}},"线程2：").start();try {Thread.sleep(10000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(atoReferenceCount.getReference());}

第二个没有执行，因为时间戳不对了。

修改下代码：

@Testpublic void test4() {for (int i = 0; i < 10; i++) {new Thread(() -> {boolean f = atoReferenceCount.compareAndSet(atoReferenceCount.getReference(),atoReferenceCount.getReference() + 1, atoReferenceCount.getStamp(),atoReferenceCount.getStamp() + 1);System.out.println("线程"+Thread.currentThread()+"result="+f);}, "线程："+i).start();}try {Thread.sleep(10000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(atoReferenceCount.getReference());}

结果：可见线程：0，比较的时候发现时间戳变了，所以没有+1。

demo2:

@Testpublic void test5() {for (int i = 0; i < 4; i++) {new Thread(() -> {for (int j = 0; j < 500; j++) {boolean f = atoReferenceCount.compareAndSet(atoReferenceCount.getReference(),atoReferenceCount.getReference() + 1, atoReferenceCount.getStamp(),atoReferenceCount.getStamp() + 1);System.out.println("线程"+Thread.currentThread()+">>j="+j+",result="+f);}}, "线程："+i).start();}try {Thread.sleep(10000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(atoReferenceCount.getReference());}

 有3次比较时间戳发现已经不同

 

参考：

https://blog.csdn.net/qq_32998153/article/details/79529704

转载于:https://www.cnblogs.com/xiaozhuanfeng/p/10846180.html

总结

以上是生活随笔为你收集整理的高并发之CAS机制和ABA问题的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得生活随笔网站内容还不错，欢迎将生活随笔推荐给好友。