美文网首页
【面试专栏】ABA问题

【面试专栏】ABA问题

作者: 霓裳梦竹 | 来源:发表于2019-12-30 17:18 被阅读0次

文章同步更新在个人公众号“梓莘”,欢迎大家关注,相互交流。

由上一篇CAS问题我们知道其容易导致ABA问题,这篇我们来学习一下相关的内容。

一、CAS为什么会导致ABA问题

CAS算法实现一个重要前提是需要取出内存中某时刻的数据并在当下时刻进行比较和替换,那么在这个时间差内会导致数据的变化。

比如说一个线程A从内存位置V中取出data,这时候另一个线程B也从内存中取出data,并且线程B进行了一些操作将值变成了data2,然后线程B又将V位置的数据变成data,这时候线程one进行CAS操作发现内存中仍然是data,然后线程A操作成功。

尽管线程A的CAS操作成功,但是并不代表这个过程就是没有问题的。

二、原子引用

要想解决这个问题我们需要先来了解一下原子引用。

放码过来

package com.zishen;

import java.util.concurrent.atomic.AtomicReference;

class User{
    String userName;
    int age;

    public String getUserName() {
        return userName;
    }

    public void setUserName(String userName) {
        this.userName = userName;
    }

    public int getAge() {
        return age;
    }

    public void setAge(int age) {
        this.age = age;
    }

    @Override
    public String toString() {
        return "User{" +
                "userName='" + userName + '\'' +
                ", age=" + age +
                '}';
    }

    public User(String userName, int age) {
        this.userName = userName;
        this.age = age;
    }
}
/**
 * @ClassName AtomicReferenceDemo
 * @Description TODO
 * @Author zishen
 * @Date 2019/12/25 19:40
 * @Version 1.0
 **/
public class AtomicReferenceDemo {

    public static void main(String[] args) {
        AtomicReference<User> atomicReference = new AtomicReference<User>();
        User u1 = new User("u1",11);
        User u2= new User("u2",22);
        atomicReference.set(u1);

        System.out.println(atomicReference.compareAndSet(u1,u2)+"\t"+atomicReference.get().toString());

    }
}

AtomicReference的作用是对“对象”进行原子操作,提供了一种读和写都是原子性的对象引用变量。也就意味着多个线程在改变同一个AtomicReference将不会使其处于不一致的状态。
其实AtomicReference与AtomicInteger非常类似,不同之处在于AtomicInteger是对整型的封装,而AtomicReference对应的是对象的引用。

三、解决方案

juc包中提供了AtomicStampedReference来解决ABA问题。可类比数据库中的乐观锁。

放码过来

package com.zishen;

import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicReference;
import java.util.concurrent.atomic.AtomicStampedReference;

/**
 * @ClassName ABADemo
 * @Description 时间戳的原子引用
 * @Author zishen
 * @Date 2019/12/25 19:50
 * @Version 1.0
 **/
public class ABADemo {

    static AtomicReference<Integer> atomicReference = new AtomicReference<>(10);

    static AtomicStampedReference<Integer> atomicStampedReference = new AtomicStampedReference<>(10,1);
    public static void main(String[] args) {
        System.out.println("以下是ABA问题的产生");
        new Thread(()->{
            atomicReference.compareAndSet(10,11);
            atomicReference.compareAndSet(11,10);
        },"t").start();
        new Thread(()->{
            try {
                //为了保证t现在完成了一次ABA操作
                TimeUnit.SECONDS.sleep(1);
                atomicReference.compareAndSet(10,12);
                System.out.println(atomicReference.get());

            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        },"t1").start();

        try {
            TimeUnit.SECONDS.sleep(2);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("以下是ABA问题的解决办法");

        new Thread(()->{
            int stamp = atomicStampedReference.getStamp();
            System.out.println(Thread.currentThread().getName()+"\t 第一次版本号"+atomicStampedReference.getStamp());
            try {
                TimeUnit.SECONDS.sleep(1);
                atomicStampedReference.compareAndSet(10,11,atomicStampedReference.getStamp(),atomicStampedReference.getStamp()+1);
                System.out.println(Thread.currentThread().getName()+"\t 第二次版本号"+atomicStampedReference.getStamp());
                atomicStampedReference.compareAndSet(11,10,atomicStampedReference.getStamp(),atomicStampedReference.getStamp()+1);
                System.out.println(Thread.currentThread().getName()+"\t 第三次版本号"+atomicStampedReference.getStamp());

            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        },"t2").start();

        new Thread(()->{
            int stamp = atomicStampedReference.getStamp();
            System.out.println(Thread.currentThread().getName()+"\t 第一次版本号"+stamp);
            try {
                //暂停t3保证t2完成一次ABA问题
                TimeUnit.SECONDS.sleep(3);
                boolean result = atomicStampedReference.compareAndSet(10,2019,stamp,stamp+1);
                System.out.println(Thread.currentThread().getName()+" 修改"+result);
                System.out.println(Thread.currentThread().getName()+" 当前最新版本号"+atomicStampedReference.getStamp());
                System.out.println(Thread.currentThread().getName()+" 当前最新值"+atomicStampedReference.getReference());
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        },"t3").start();
    }
}

书写不易,转载请注明出处。

相关文章

  • 【面试专栏】ABA问题

    文章同步更新在个人公众号“梓莘”,欢迎大家关注,相互交流。 由上一篇CAS问题我们知道其容易导致ABA问题,这篇我...

  • 死磕 java并发包之AtomicStampedReferenc

    问题 (1)什么是ABA? (2)ABA的危害? (3)ABA的解决方法? (4)AtomicStampedRef...

  • 原子操作 CAS CompareAndSwap

    参考 Java CAS ABA问题发生的场景分析 提到了ABA问题 Unsafe$compareAndSwapIn...

  • 2020-08-26:CAS实现原子操作的三大问题?

    前言 每日一题专栏 CAS实现原子操作的三大问题? ABA问题: 因为CAS需要在操作值的时候,检查值有没有发生变...

  • ABA问题

    CAS会导致“ABA问题”。 线程1准备用CAS将变量的值由A替换为C,在此之前,线程2将变量的值由A替换为B,又...

  • 细谈CAS与ABA

    题目:如何实现乐观锁(CAS),如何避免ABA问题? 这个题主要考查原子操作、悲观锁、乐观锁及ABA问题。 原子操...

  • CAS ABA问题

    java.util.concurrent包的最底层基础CAS技术,原理很简单。 CAS有3个操作数,内存值V,旧的...

  • 并发和Read-copy update(RCU)

    简介 在上一篇文章中的并发和ABA问题的介绍中,我们提到了要解决ABA中的memory reclamation问题...

  • Java多线程22 Atomic

    ABA问题 输出true 解决 添加版本号

  • JUC之ABA问题

    什么是ABA问题? ABA问题是由CAS而导致的一个问题 CAS算法实现一个重要前提需要取出内存中某时刻的数据并在...

网友评论

      本文标题:【面试专栏】ABA问题

      本文链接:https://www.haomeiwen.com/subject/akvmoctx.html