CAS无锁优化&ABA问题

2020-04-29  本文已影响0人  silence_J

本文内容:

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问题。

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

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

Unsafe(了解即可)

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

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

上一篇下一篇

猜你喜欢

热点阅读