美文网首页
CAS无锁优化&ABA问题

CAS无锁优化&ABA问题

作者: silence_J | 来源:发表于2020-04-29 09:57 被阅读0次

本文内容:

Atomic原子类
CAS(无锁优化,乐观锁)
ABA问题
Unsafe

对某些常见操作,加锁的情况有很多,所以Java提供了一些类来实现这种操作,这些类内部自动带了锁,但这锁不是synchronized实现,而是CAS的操作来实现的。

Atomic原子类

以AtomicXXX开头的都是用CAS操作来保证线程安全的类。

在开发工作中经常有多个线程共同访问一个值,改变一个值的场景,这时就可以使用原子类如AtomicInteger。这里面包含了int类型,这个int类型的自增count++是线程安全的,取值也是线程安全的。

如下,不用再对m()加synchronized,输出一定为10万

public class AtomicInteger_01 {

    AtomicInteger count = new AtomicInteger(0);

    void m() {
        for (int i=0; i<10000; i++) {
            count.incrementAndGet(); // 自增 count++
        }
    }

    public static void main(String[] args) {
        AtomicInteger_01 instance = new AtomicInteger_01();
        List<Thread> threads = new ArrayList<>();
        for (int i=0; i<10; i++) {
            threads.add(new Thread(instance::m, "thread-"+i));
        }

        threads.forEach( thread -> thread.start());

        threads.forEach( thread -> {
            try {
                thread.join(); // 自增线程执行完后才执行主线程
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });

        System.out.println(instance.count);
    }
}

CAS原理

原子类内部都使用了CAS,上面代码的自增方法

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

incrementAndGet()方法调用了getAndAddInt 这是一个CompareAndSetInt操作

@HotSpotIntrinsicCandidate
public final int getAndAddInt(Object o, long offset, int delta) {
    int v;
    do {
        v = getIntVolatile(o, offset);
    } while (!weakCompareAndSetInt(o, offset, v, v + delta));
    return v;
}

也就是说AtomicInteger它的内部是调用了Unsafe这个类里面的方法CompareAndSetInt(CAS),字面意思是比较且设定。要改变某个值,想要线程安全可以加锁synchronized,现在可以用另一种操作来代替加锁操作,这就是CAS操作。

CAS执行原理

为了说明问题将CAS操作想象成一个方法 cas(V, Expected, NewValue),V是需要被修改的那个值,Expected是期望当前这个V是几,NewValue是要设置的新值。

// 伪代码
cas(V, Expected, NewValue){
    if (V == Expected) {
        V = NewValue;
    } else {
        try again or fail
    }
}

比如要把1改为2。这时参数V=1,因为期望进行赋值操作时V没被别的线程修改所以Expected=1,NewValue=2。如果V == Expected,正常赋值;如果其它某个线程把V改为了2,V != Expected,这个线程会重新尝试,这时V=2,Expected=2......如此运行。这就是CAS操作,本质上是这么个运行过程。

简言之,Expected期望值和V实际值相等才会进行新值设定,V被其他线程改了后,当前线程会重试或失败,这就是CAS操作。

注意!
判断V==Expected后,赋值操作前不会再有别的线程进来改变V。CAS是CPU的原语支持,也就是说CAS操作是CPU指令级别上的支持,中间不能被打断。以上代码只是为了方便解释的伪代码。

ABA问题

CAS可以有效提升并发效率,但同时也会引入ABA问题。

  • 什么是ABA问题?
    比如要把1变成2,A线程从内存中取出1,B线程也从内存中取出1并且将1改成2后又改回1,这时不会影响A线程进行CAS操作,这就是ABA问题。

所以JAVA中提供了AtomicStampedReference/AtomicMarkableReference来处理会发生ABA问题的场景,主要是在对象中额外再增加一个标记来标识对象是否有过变更。任何一个值的修改都使版本号加1,检查时连版本号一起检查。

如果是基础类型:无所谓,不影响结果值。
如果是引用类型:就像你的女朋友跟你分手后又复合,中间经历了别的男人。

Unsafe(了解即可)

Unsafe可以看作C或C++中的指针,它可以:

  • 直接操作内存
    allocateMemory,putXX,freeMemory,pageSize
  • 直接生成类实例
    allocateInstance
  • 直接操作类或实例变量
    objectFieldOffset
    getInt
    getObject
  • CAS相关操作
    weakCompareAndSetXXX(Object Int Long ...)

这个类不能被直接使用,需要利用反射使用,不能直接使用是和ClassLoader有关。所有的Atomic类操作内部都是使用CAS,而CAS就是在Unsafe类里完成的。

相关文章

  • CAS无锁优化&ABA问题

    本文内容: Atomic原子类CAS(无锁优化,乐观锁)ABA问题Unsafe 对某些常见操作,加锁的情况有很多,...

  • 细谈CAS与ABA

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

  • 并发编程-Synchronized锁

    上一篇 <<

  • JAVA并发面试题

    1,CAS的ABA问题 独占锁:是一种悲观锁,synchronized就是一种独占锁,会导致其它所有需要锁的线程挂...

  • 原子操作 CAS CompareAndSwap

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

  • 并发编程-CAS无锁模式及ABA问题

    上一篇 <<

  • CAS中的ABA问题

    补档CAS中的ABA问题。 要特别注意,常见的ABA问题有两种,要求能分别举例解释。 CAS的使用可参考:源码|并...

  • CAS ABA问题

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

  • 线程基础回顾

    synchronized volatile (读写屏障) CAS (无锁优化 自旋) 中间不能被打断 包:java...

  • JUC之ABA问题

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

网友评论

      本文标题:CAS无锁优化&ABA问题

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