JUC练习16——CAS

一,什么是CAS

CAS就是compareAndSet的缩写,他会比较内存中的值是否是期望的值,如果期望的值就执行操作,否则会由于它的底层是自旋锁而等待操作的执行。

public static void main(String[] args)  {
       AtomicInteger atomicInteger = new AtomicInteger(2021);
        //CAS就是compareAndSet的缩写,期望的值为2021,如果满足就将数据更新为2022,否则不更新
       atomicInteger.compareAndSet(2021,2022);
    }

优点:操作的原子性

缺点:

自旋锁的循环会耗时

一次只能保证一个共享变量的原子性

有ABA问题

 

二,ABA问题

什么是ABA:一个线程将数据A修改为B后再修改为A,另外一个线程发觉不了,因为它拿到数据为A认为没有被修改过,就执行A修改为B

例子:

  线程1:想要将2021修改为2022,如果期望的值为2021就可以修改成功

  线程2:为一个捣乱的线程,它先将2021修改为2022,然后线程会对拿到的值进行其它一系列的非法操作,

  最终将2022修改为2021,给线程1一个错觉执行成功

代码示例:

static AtomicInteger atomicInteger = new AtomicInteger(2021);
    public static void main(String[] args) throws InterruptedException {
        new Thread(()->
        {
            //捣乱的线程
            atomicInteger.compareAndSet(2021,2022);
            System.out.println(atomicInteger.get());
            System.out.println(Thread.currentThread().getName()+"拿着修改后的值进行非法操作");
            atomicInteger.compareAndSet(2022,2021);
            System.out.println(atomicInteger.get());
        }).start();
        TimeUnit.SECONDS.sleep(2);
        //实际执行的线程
        atomicInteger.compareAndSet(2021,2022);
        System.out.println(atomicInteger.get());
    }

如何解决ABA问题?

使用原子引用来解决

//通过版本号来防止修改(乐观锁)
    static AtomicStampedReference<Integer> atomicStampedReference = new AtomicStampedReference<>(100,1);
    public static void main(String[] args) throws InterruptedException {
        new Thread(()->
        {
            System.out.println("线程1进入时的版本号:"+atomicStampedReference.getStamp());
            try {
                TimeUnit.SECONDS.sleep(2);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            boolean updateSuccess1 = atomicStampedReference.compareAndSet(100, 101,
                    atomicStampedReference.getStamp(), atomicStampedReference.getStamp() + 1);
            System.out.println(atomicStampedReference.getStamp());
            System.out.println("线程1修改1:"+updateSuccess1);
            boolean updateSuccess2 = atomicStampedReference.compareAndSet(101,100,
                    atomicStampedReference.getStamp(),atomicStampedReference.getStamp()+1);
            System.out.println(atomicStampedReference.getStamp());
            System.out.println("线程1修改2:"+updateSuccess2);
        }).start();
        new Thread(()->
        {
            System.out.println("线程2进入时的版本号:"+atomicStampedReference.getStamp());
            try {
                TimeUnit.SECONDS.sleep(2);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            //实际执行的线程
            boolean updateSuccess3 = atomicStampedReference.compareAndSet(100,101,
                    atomicStampedReference.getStamp(),atomicStampedReference.getStamp()+1);
            System.out.println(atomicStampedReference.getStamp());
            System.out.println("线程2修改:"+updateSuccess3);
        }).start();
    }
上一篇:Pytorch实现LeNet


下一篇:【六级单词】2022.2.16