Juc并发编程10——原子类与ABA问题解决方案(上)

简介: 除了加锁以外,还可以使用原子类实现操作原子性。它底层采用CAS算法,使用简单、性能高效、线程安全

除了加锁以外,还可以使用原子类实现操作原子性。它底层采用CAS算法,使用简单、性能高效、线程安全。


简单示范下它的使用。

public class Demo24 {
    public static void main(String[] args) {
        AtomicInteger integer = new AtomicInteger(1);  // 不能向Integer一样自动装箱(Integer i = 1)
        System.out.println(integer.getAndIncrement()); //相当于i++
        System.out.println(integer.incrementAndGet()); //相当于++i
    }
}

如何验证它的原子性呢?看看下面的代码。

public class Demo25 {
    public static void main(String[] args) throws InterruptedException {
        AtomicInteger integer = new AtomicInteger();
        Runnable r = new Runnable() {
            @Override
            public void run() {
                for (int i = 0; i < 1000000; i++) {
                    integer.getAndIncrement();
                }
                System.out.println("thread finish...");
            }
        };
        new Thread(r).start();
        new Thread(r).start();
        TimeUnit.SECONDS.sleep(1);
        System.out.println(integer.get());
    }
}

运行输出的结果如下。确实是原子性的哦。


thread finish...
thread finish...
2000000


为什么会这么神奇呢?我们来阅读下源码一探究竟吧。

private volatile int value;
  public AtomicInteger(int initialValue) {
        value = initialValue;
   }
   public AtomicInteger() {
   }

它使用volatile关键字修饰了value,这样在CAS操作时就不会出错。

private static final Unsafe unsafe = Unsafe.getUnsafe();
    private static final long valueOffset;
    static {
        try {
            valueOffset = unsafe.objectFieldOffset
                (AtomicInteger.class.getDeclaredField("value"));
        } catch (Exception ex) { throw new Error(ex); }
    }

在静态块中,通过计算偏移地址,获取value相对于对象的偏移地址,这样就可以直接在对应内存对数据进行操作。


接着看看自增操作是如何完成的。

public final int getAndIncrement() {
        return unsafe.getAndAddInt(this, valueOffset, 1);
    }

到Unsafe中看看。下面的参数列表中var1是数组或者对象(要修改的值是数组的元素或者对象的属性),var2是offset偏移地址,var4是delta,参数变化量。可以看到,它是一个do-while循环,如果CAS失败会重新尝试,一直到成功。

public final int getAndAddInt(Object var1, long var2, int var4) {
        int var5;
        do {
            var5 = this.getIntVolatile(var1, var2); // 以Volatile形式读取变量的值
        } while(!this.compareAndSwapInt(var1, var2, var5, var5 + var4)); //对变量进行CAS操作
        return var5;
    }


为了帮助大家更加深入理解,我举一个例子。比如线程1,2同时对变量A进行修改,线程1速度较快,读到它的值是1,准备CAS操作,线程2此时也开始读到数据是1,但是进行CAS操作时线程1在执行,因此它无法CAS成功。当线程1执行完CAS操作后,数据A的值变成2。此时线程2尝试下一轮获取变量的值就是2(变量通过volitile修饰了),然后进行CAS操作值就变成了3.不过由于是do-while循环,var5的值仍然是2,getAndAddInt返回的参数是2,因此也符合getAndIncrement的逻辑定义(先获取值再自增)。


用图片描述下。

如果是incrementAndGet的话,其底层逻辑会不会是while循环呢?答案是否,大家看看源码。


public final int incrementAndGet() {
        return unsafe.getAndAddInt(this, valueOffset, 1) + 1;
    }

原来是在原来的return的值基础上+1,这样就可以复用一个底层方法getAndAddInt实现两个不同的逻辑。这个思想值得大家学习呀。

可见,原子类底层也是采用CAS算法保证的操作原子性,并且它提供了compareAndSet直接给外部使用。

    // 第一个值是期望值,第二个值是要更新后数据,符合期望值expect就会更新数据为update
    public final boolean compareAndSet(int expect, int update) {
        return unsafe.compareAndSwapInt(this, valueOffset, expect, update);
    }

写个demo测试下

public class Demo26 {
    public static void main(String[] args) {
        AtomicInteger integer = new AtomicInteger(10);
        integer.compareAndSet(20, 15); // fail
        System.out.println(integer);
        integer.compareAndSet(10, 30); // success
        System.out.println(integer);
    }
}


目录
打赏
0
0
0
0
4
分享
相关文章
|
10月前
|
剑指JUC原理-4.共享资源和线程安全性(上)
剑指JUC原理-4.共享资源和线程安全性
94 1
|
10月前
|
剑指JUC原理-2.线程
剑指JUC原理-2.线程
77 0
JAVA并发编程JUC包之CAS原理
在JDK 1.5之后,Java API引入了`java.util.concurrent`包(简称JUC包),提供了多种并发工具类,如原子类`AtomicXX`、线程池`Executors`、信号量`Semaphore`、阻塞队列等。这些工具类简化了并发编程的复杂度。原子类`Atomic`尤其重要,它提供了线程安全的变量更新方法,支持整型、长整型、布尔型、数组及对象属性的原子修改。结合`volatile`关键字,可以实现多线程环境下共享变量的安全修改。
【多线程面试题二十五】、说说你对AQS的理解
这篇文章阐述了对Java中的AbstractQueuedSynchronizer(AQS)的理解,AQS是一个用于构建锁和其他同步组件的框架,它通过维护同步状态和FIFO等待队列,以及线程的阻塞与唤醒机制,来实现同步器的高效管理,并且可以通过实现特定的方法来自定义同步组件的行为。
【多线程面试题二十五】、说说你对AQS的理解
深入剖析Java并发库(JUC)之StampedLock的应用与原理
深入剖析Java并发库(JUC)之StampedLock的应用与原理
深入剖析Java并发库(JUC)之StampedLock的应用与原理
JUC中的原子操作类及其原理
JUC中的原子操作类及其原理
第二季:5公平锁/非公平锁/可重入锁/递归锁/自旋锁谈谈你的理解?请手写一个自旋锁【Java面试题】
第二季:5公平锁/非公平锁/可重入锁/递归锁/自旋锁谈谈你的理解?请手写一个自旋锁【Java面试题】
86 0
|
10月前
|
剑指JUC原理-4.共享资源和线程安全性(下)
剑指JUC原理-4.共享资源和线程安全性
64 0
JUC第十二讲:JUC锁 - 看不懂锁核心类 AQS 原理来打我
JUC第十二讲:JUC锁 - 看不懂锁核心类 AQS 原理来打我
JUC并发编程(四):synchronized底层原理和锁升级优化
`synchronized`翻译过来是**同步**的意思,它是Java中一个关键字,是JVM层面提供的同步锁机制,用于保证多线程访问同一资源的可见性、互斥性。即当一个线程已经获取资源锁时,其他试图获取的线程只能等待或者阻塞在那里。
120 0
JUC并发编程(四):synchronized底层原理和锁升级优化