源码导读-帮助篇-什么叫做CAS算法【图文版】

CAS是Compare And Swap的缩写,翻译过来就是比较替换算法。

1. 什么叫做CAS

CAS机制就是使用了3个基本操作数:内存地址V的当前值,旧的预期值A,要修改的新值B。

当修改一个变量的时候,只有当变量的旧的预期值A内存地址V当前值相同时,要修改的值B才会修改内存地址V的值

这个内存地址很关键呀。表明了它是操作系统层级的算法。Java内存模型中指出,Java内存模型规定了所有变量(不包括局部变量)存放在主存中,每条线程也有自己的工作内存。线程对变量的所有操作,均在工作内存中进行。

  1. 在内存地址V中,存储着值为10的变量。


    原始内存地址
  2. 此时线程001想把变量的值增加1,对于线程001来说,旧的预期值A=10,要修改的新值B=11。线程001在其自己的工作内存中将变量值修改成为了11。

修改线程001工作内存的值
  1. 在线程001将数据flush到主内存之前,另一个线程002抢先一步,将线程002工作内存的值刷新到了主内存中
线程002刷新主内存的值

---华丽分割线(CAS如何保证原子性呢)---

  1. 线程001将工作内存的值刷新到主内存中时,首先进行旧预期值A和内存地址V进行比较,发现内存V上的不是A,提交失败。
    线程001提交失败

---华丽的分割线(CAS算法结束)---

  1. 【自旋】(程序员设置死循环)线程001没辙,重新获取内存地址V的当前值,并重新计算想要修改的值。对于线程1来说,A此时等于11,B=12。这个重新尝试的过程叫做自旋。
线程001自旋
  1. 这一次比较幸运,没有其他线程改变内存地址V的当前值,线程001进行比较,发现预期旧值A(11)和内存地址V当前值V(11)是相等的。于是进行替换。
最终结果

从思想上来说,synchronize属于悲观锁,对外界的修改持悲观态度。具有独占性和排他性。而CAS属于乐观锁,乐观的认为程序中的并发情况不那么严重,所有让线程去不断的重试更新。

1.2 如何实现CAS算法?

CAS算法实现的关键就是“如何获取内存地址V的当前值”

1. AtomicInteger的compareAndSet方法:

    private static final Unsafe unsafe = Unsafe.getUnsafe();
     //定义内存地址V
    private static final long valueOffset;
    //获取参数的内存地址V
    static {
      try {
        valueOffset = unsafe.objectFieldOffset
            (AtomicInteger.class.getDeclaredField("value"));
      } catch (Exception ex) { throw new Error(ex); }
    }
    //保证内存地址V元素的可见性
    private volatile int value;
    //本质上获取的值均存入value中
     public AtomicInteger(int initialValue) {
        value = initialValue;
    }
    public AtomicInteger() {
    }
    public final int get() {
        return value;
    }
    public final void set(int newValue) {
        value = newValue;
    }

    //调用方法
    public final boolean compareAndSet(int expect, int update) {
        return unsafe.compareAndSwapInt(this, valueOffset, expect, update);
    }

这个方法就是传入的expect(旧预期值)和内存地址valueOffset上当前值相比较。如果相等的话,那么就是要update来替换expect的值。

2. ReentrantLock.Sync的compareAndSetState方法:

实现CAS算法的关键是:

  1. 将(原子性)变量设置为volatile修饰,保证其可见性;
  2. 获取(原子性)变量的内存地址valueOffset。
  3. 进行CAS算比较。
 private volatile int state;

 private static final Unsafe unsafe = Unsafe.getUnsafe();
 private static final long stateOffset;
 static {
        try {
            stateOffset = unsafe.objectFieldOffset
                (AbstractQueuedSynchronizer.class.getDeclaredField("state"));
        } catch (Exception ex) { throw new Error(ex); }
    }
  protected final boolean compareAndSetState(int expect, int update) {
        // See below for intrinsics setup to support this
        return unsafe.compareAndSwapInt(this, stateOffset, expect, update);
    }

即可实现CAS算法。

2. CAS的缺点

1. CPU开销大
在并发量比较高的情况下,如果大量线程反复重试更新某一个变量,却一直更新不成功,循环往复,会给CPU带来很大的压力。

2. 不能保证代码块的原子性
CAS机制所保证的只是一个变量的原子性操作,而不能保证整个代码块的原子性。如果需要保证3个变量共同进行原子性的更新,就不得不使用synchronize了。

3. ABA问题

这是CAS机制最大的问题所在。

下面来介绍CAS的底层实现:

  1. JAVA的CAS底层实现。
  2. CAS的ABA问题和解决方法。
public final int incrementAndGet() {
    for (;;) {
        int current = get();
        int next = current + 1;
        if (compareAndSet(current, next))
            return next;
    }
}
private volatile int value; 
public final int get() {
    return value;
}

这是一个死循环,也就是CAS自旋。循环体做了3件事:

  1. 获取当前值【内存地址V的当前值,其实也就是旧预期值A的值】
  2. 当前值+1,计算出目标值【要替换的值B】
  3. 进行CAS操作,如果成功则跳出循环,如果失败则重复上述步骤。

我们可以看到get()方法,这个方法的作用就是获取变量的当前值。
如何保证获取到的当前值是内存中的最新值呢?
小胖:可以使用关键字volatile来保证。

我们接着看下compareAndSet(int expect,int update)的实现。

public final boolean compareAndSet(int expect,
int update)如果当前值为 ==为预期值,则将该值原子设置为给定的更新值。
参数
expect - 预期值
update - 新价值
结果
true如果成功。 False return表示实际值不等于预期值。

   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); }
    }

   public final boolean compareAndSet(int expect, int update) {
        return unsafe.compareAndSwapInt(this, valueOffset, expect, update);
    }

compareAndSet方法很简单,只有一行代码,这里涉及到了两个重要的对象:unsafevalueOffset

什么是unsafe呢?java语言不像C,C++那样可以直接访问底层操作系统,但是JVM为我们提供了一个后门,这就是unsafe。unsafe为我们提供硬件级别的原子操作。

至于valueOffset对象,是通过unsafe.ObjectFieldOffset方法得到,所代表的就是AtomicInteger对象value成员变量在内存中的偏移量。我们可以简单的把valueOffset理解为value变量的内存地址。

上面说过,CAS机制使用了3个基本操作数:内存地址V的当前值,旧的预期值A,要修改的新值B。

而unsafe的compareAndSwapInt方法的参数包括了这三个基本元素:valueOffset参数代表了V,expect参数代表A,update参数代表B。

正是unsafe的compareAndSwapInt方法保证了Compare
和Swap操作之间的原子性操作。

那什么是ABA问题呢?

假设有一个提款机的例子,假设有一个遵循CAS原理的提款机,小灰有100元存款,要用这个提款机来提款50元。

准备提款的小灰QAQ

但是提款机硬件有一些问题,小灰的提款请求被同时提交了两次,开启了两个线程,两个线程都是获取当前值100元,要更新成50元。

两次扣款请求

线程1首先执行成功,把余额从100改成了50,线程2因为某些原因阻塞。这时,小灰的妈妈刚好给小灰汇款50元。

小灰妈汇款

线程2仍然处于阻塞状态,线程3执行成功,把余额从50改成了100。

汇款成功

线程2恢复运行,由于阻塞之前获取了“当前值100”,并经过compare检测,此时存款实际值也是100,所有会成功的把变量值100更新成50元。

再次扣款

原本线程2应当提交失败的,小灰的正确余额应该保持100元,结果由于ABA问题提交成功了。

如何解决这个问题呢?

加个版本号就可以了。真正要做到严谨的CAS机制,我们在compare阶段不仅要比较1期望值A和地址V中的实际值,还要比较变量的版本号是否一致。

在Java中,AtomicStampedReference类就实现了用版本号做额外的CAS比较。

public static void main(String[] args) {
        String oldStr = "aaa";
        String newStr = "bbb";
        //构造方法,传入引用和戳
        AtomicStampedReference<String> reference =
                new AtomicStampedReference<>(oldStr, 1);
        //旧预期值,要替换的新值,旧时间戳,新时间戳
        //如果A=V,那么将b更新到V,并更新时间戳。
        reference.compareAndSet(oldStr, newStr, reference.getStamp(),
                reference.getStamp() + 1);
        System.out.println("内存V中的当前值:" + reference.getReference()
                + ",内存V中当前戳" + reference.getStamp());
        //更新内存V中的时间戳
        boolean result = reference.attemptStamp(newStr, reference.getStamp() + 1);
        System.out.println("是否更新成功:"+result);
        System.out.println("内存V中的当前戳"+reference.getStamp());
    }
}

运行结果:

内存V中的当前值:bbb,内存V中当前戳2
是否更新成功:true
内存V中的当前戳3
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 218,204评论 6 506
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 93,091评论 3 395
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 164,548评论 0 354
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,657评论 1 293
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,689评论 6 392
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,554评论 1 305
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,302评论 3 418
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 39,216评论 0 276
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,661评论 1 314
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,851评论 3 336
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,977评论 1 348
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,697评论 5 347
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,306评论 3 330
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,898评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 33,019评论 1 270
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 48,138评论 3 370
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,927评论 2 355

推荐阅读更多精彩内容