package com.shi.CAS;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicStampedReference;
/**
* ABA问题案例
* @author shiye
*
*/
public class ABATest1 {
static AtomicInteger auAtomicInteger = new AtomicInteger(100);
static AtomicStampedReference<Integer> atomicStampedReference = new AtomicStampedReference<>(100,1);
public static void main(String[] args) throws InterruptedException {
System.out.println("===============ABA问题的产生===============");
new Thread(()-> {
boolean a1 = auAtomicInteger.compareAndSet(100, 200);
System.out.println(Thread.currentThread().getName() + a1 + " 第一次 修改之后的值为 " + auAtomicInteger.get());
boolean a2 = auAtomicInteger.compareAndSet(200, 100);
System.out.println(Thread.currentThread().getName() + a2 + " 第二次 修改之后的值为 " + auAtomicInteger.get());
},"线程A ").start();
new Thread(()-> {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
boolean b1 = auAtomicInteger.compareAndSet(100, 2019);
System.out.println(Thread.currentThread().getName() + b1 + " 第一次 修改之后的值为 " + auAtomicInteger.get());
},"线程B ").start();
Thread.sleep(3000);
System.out.println("===============ABA问题的解决===============");
new Thread(()->{
int stamp1 = atomicStampedReference.getStamp();//获取版本
System.out.println(Thread.currentThread().getName() + "当前版本是： " + stamp1);
try {
Thread.sleep(1000);//睡眠1s
} catch (InterruptedException e) {
e.printStackTrace();
}
boolean C1 = atomicStampedReference.compareAndSet(100, 499, stamp1, stamp1+1);
System.out.println(Thread.currentThread().getName() + C1 + " 第一次 修改之后的值为 " + atomicStampedReference.getReference() + " 版本号为： " + atomicStampedReference.getStamp());
int stamp2 = atomicStampedReference.getStamp();//获取版本
boolean C2 = atomicStampedReference.compareAndSet(499, 100, stamp2, stamp2+1);
System.out.println(Thread.currentThread().getName() + C2 + " 第二次 修改之后的值为 " + atomicStampedReference.getReference() + " 版本号为： " + atomicStampedReference.getStamp());
},"线程C ").start();
new Thread(()->{
int stamp1 = atomicStampedReference.getStamp();//获取版本
System.out.println(Thread.currentThread().getName() + "当前版本是： " + stamp1);
try {
Thread.sleep(3000);//睡眠3s
} catch (InterruptedException e) {
e.printStackTrace();
}
boolean d1 = atomicStampedReference.compareAndSet(100, 2019, stamp1, stamp1+1);
System.out.println(Thread.currentThread().getName() + d1 + " 第一次 修改之后的值为 " + atomicStampedReference.getReference() + " 版本号为： " + atomicStampedReference.getStamp());
},"线程D ").start();
}
}
执行结果：
===============ABA问题的产生===============
线程A true 第一次 修改之后的值为 200
线程A true 第二次 修改之后的值为 100
线程B true 第一次 修改之后的值为 2019
===============ABA问题的解决===============
线程C 当前版本是： 1
线程D 当前版本是： 1
线程C true 第一次 修改之后的值为 499 版本号为： 2
线程C false 第二次 修改之后的值为 499 版本号为： 2
线程D false 第一次 修改之后的值为 499 版本号为： 2