什么是CAS机制

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

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

高并发之CAS机制和ABA问题-LMLPHP

看如下几个例子:

package com.example.demo.concurrentDemo;

import org.junit.Test;

import java.util.concurrent.atomic.AtomicInteger;

public class CasTest {

    private static int count = 0;

    @Test
public 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);
} @Test
public 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); @Test
public 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对象封装了引用和时间戳信息。

高并发之CAS机制和ABA问题-LMLPHP

高并发之CAS机制和ABA问题-LMLPHP

Demo:

 @Test
public 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());
}

高并发之CAS机制和ABA问题-LMLPHP

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

修改下代码:

 @Test
public 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。

高并发之CAS机制和ABA问题-LMLPHP

demo2:

@Test
public 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次比较时间戳发现已经不同

高并发之CAS机制和ABA问题-LMLPHP

参考:

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

05-27 06:30