原创

CAS的ABA问题及解决方案

问题说明:

ABA问题是CAS的两个线程在处理某个数据的时候,当t1线程的执行时间较长,比如时间在10秒钟,t2线程的执行时间在2秒钟。在t1还没
执行完成的过程中,t2线程将值从100改成101,然后t2再次将值101改成了100,此时,t1线程并不知道t2线程干了什么猫腻。t1线程再次
去将100修改成2020是可以成功的,但是数值本身是被修改过的,不应该修改成功,所以这里就是出现了ABA问题

解决方案:

使用原子引用的带版本号的工具:AtomicStampReference类来解决,比如:t1的修改时间较长,t2每做一次修改,就给版本号加1,这样子
在CAS的时候,不仅仅需要比对值的是否相等,还需要比对版本号是否相等,这样即使t2修改了两次,t1在去修改的时候,仍然能够感知到
版本号不同,也就会引起修改失败,这样子就解决了ABA问题。

示例代码:

import java.util.concurrent.atomic.AtomicStampedReference;

public class Test {
    static AtomicStampedReference atomicStampedReference = new AtomicStampedReference(100, 1);

    public static void main(String[] args) {
        //ABA问题的解决
        new Thread(() -> {
            int stamp = atomicStampedReference.getStamp();
            System.out.println(Thread.currentThread().getName() + "\t 线程第一次的版本号:" + stamp);

            //执行ABA操作
            atomicStampedReference.compareAndSet(100,101,
                    atomicStampedReference.getStamp(),atomicStampedReference.getStamp() + 1);
            System.out.println(Thread.currentThread().getName() + "\t 线程第二次的版本号:" 
                    + atomicStampedReference.getStamp());
            atomicStampedReference.compareAndSet(101,100,
                    atomicStampedReference.getStamp(),atomicStampedReference.getStamp() + 1);
            System.out.println(Thread.currentThread().getName() + "\t 线程第三次的版本号:" 
                    + atomicStampedReference.getStamp());
        },"t1").start();

        new Thread(() -> {
            int stamp = atomicStampedReference.getStamp();
            System.out.println(Thread.currentThread().getName() + "\t 线程第一次的版本号:" + stamp);
            try{
                Thread.sleep(1000);
            }catch(Exception e){
                e.printStackTrace();
            }
            boolean b = atomicStampedReference.compareAndSet(100, 
                    2019, stamp, stamp + 1);
            System.out.println(Thread.currentThread().getName() + "\t 线程修改成功与否:" + b + "当前最新实际版本号:" 
                    + atomicStampedReference.getStamp());
            System.out.println(Thread.currentThread().getName() + "当前最新实际值:" 
                    + atomicStampedReference.getReference());

        },"t2").start();
    }
}
正文到此结束
本文目录