对CAS的一点理解

2017-05-07  本文已影响1107人  大海孤了岛

在了解CAS之前,我们先来探讨一下如何实现自增(即i++操作):为保证它线程安全的,我们通常会采用volatile+synchronized方法来保证其安全性,如下

public class LockDemo {
    private volatile int value;

    public synchronized int incrementAndGet(){
        return ++value;
    }
}

但实际上,我们知道有一种更加简便的方法:使用AtomicInteger原子类实现

public class AtomicDemo {
    private AtomicInteger value = new AtomicInteger();

    public int incrementAndGet(){
        return value.incrementAndGet();
    }
}

我们知道它在自增时,调用的本身的incrementAndGet()方法,那么我们就来探究下这个方法是如何保证线程安全性的:

//使用volatile关键字保证线程可见性
private volatile int value;
public final int get(){
    return value;
}

public final int incrementAndGet(){
    for (; ; ) {
        int current = get();
        int next = current + 1;
        if (compareAndSet(current, next))
            return next;
    }
}

通过上面的代码,我们可以看到它是通过调用compareAndSet方法来实现自增,若更新成功,则返回结果,否则重试。而这里的compareAndSet方法实际上就是我们所说的CAS。

CAS的含义

比较交换(CAS)指令包含了3个操作数——需要读写的内存位置V、进行比较的值A和拟写入的新值B。当且仅当V的值等于A,CAS才会通过原子方式用新值B来更新V的值,否则不会执行任何操作。通俗来讲,就是“我认为V的值应该为A,如果是,那么将V的值更新为B,否则不修改并告诉V的值实际是多少”。

我们通过模拟实现一个CAS来加深对其操作的理解:

public class SimulatedCAS {
    private int value;
    
    public synchronized int get(){
        return value;
    }
    
    public synchronized int compareAndSwap(int expectedValue, int newValue){
        int oldValue = value;
        if (oldValue == expectedValue){
            value = newValue;
        }
        return oldValue;
    }
    
    public synchronized boolean compareAndSet(int expectedValue, int newValue){
        return (expectedValue == compareAndSwap(expectedValue,newValue));
    }
}

CAS的应用场景

  • 常见的原子类中都使用到了CAS,比如上面所用的AtomicInteger中就是通过CAS来实现自增。

如下,通过CAS实现范围数的设定

public class CasNumberRange {
    private static class IntPair{
        final int lower;
        final int upper;

        public IntPair(int lower, int upper) {
            this.lower = lower;
            this.upper = upper;
        }
    }
    
    private final AtomicReference<IntPair> values = 
            new AtomicReference<IntPair>(new IntPair(0,0));
    
    public int getLower() { return values.get().lower; }
    public int getUpper() { return values.get().upper; }
    
    public void setLower(int i){
        while (true){
            IntPair oldValue = values.get();
            if (i > oldValue.upper)
                throw new IllegalArgumentException("Can't set lower to " + i + " > upper");
            IntPair newValue = new IntPair(i,oldValue.upper);
            //更新成功退出循环
            if (values.compareAndSet(oldValue,newValue))
                return;
        }
    }
    
    public void setUpper(int i){
        while (true){
            IntPair oldValue = values.get();
            if (i < oldValue.lower)
                throw new IllegalArgumentException("Can't set lower to " + i + " < lower");
            IntPair newValue = new IntPair(oldValue.lower,i);
            if (values.compareAndSet(oldValue,newValue))
                return;
        }
    }
    
}

如上,通过AtomicReference和InPair来保存状态,并通过使用compare-AndSet来保证在更新上下界时能避免NumberRange的竞态条件。

CAS的优缺点

  • 优点:在一般情况下,性能优先于锁的使用。
上一篇 下一篇

猜你喜欢

热点阅读