CAS算法

我们知道java中volatile关键字,它是一个轻量级的锁并且不支持原子操作

一 基本概念

CAS算法

CAS (Compare-And-Swap) 是一种硬件对并发的支持,针对多处理器操作而设计的处理器中的一种特殊指令,用于管理对共享数据的并发访问。

CAS是一种无锁的非阻塞算法(乐观锁)的实现,当多个线程尝试使用CAS同时更新同一个变量时,只有其中一个线程能更新变量的值,而其它线程都失败,失败的线程并不会被挂起,而是被告知这次竞争中失败,并可以再次尝试。CAS有3个操作数,内存值V,旧的预期值A,要修改的新值B。当且仅当预期值A和内存值V相同时,将内存值V修改为B,否则什么都不做。在 java.util.concurrent.atomic 包下面的所有的原子变量类型都实现了这项技术。

需要读写的内存值 V
进行比较的值 A
拟写入的新值 B

当且仅当 V 的值等于 A 时, CAS 通过原子方式用新值 B 来更新 V 的值,否则不会执行任何操作。

演示与分析

多线程情况下的原子性问题

public class CASTest {
    public static void main(String[] args) {

        DemoRunnable dr = new DemoRunnable();

        for (int i = 0; i < 10; i++) {
            new Thread(dr).start();
        }
    }
}
class DemoRunnable implements Runnable {
    private volatile int ai ;
    @Override
    public void run() {
        try {
            Thread.sleep(200);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("子线程-count:" + (ai++));
    }
}

打印结果这里为

子线程-count:0
子线程-count:4
子线程-count:3
子线程-count:2
子线程-count:1
子线程-count:0
子线程-count:5
子线程-count:6
子线程-count:7
子线程-count:8

最中结果不会累加为10

解决方法

在 java.util.concurrent.atomic 包中,提供了很多支持原子操作的类。如:AtomicBoolean、AtomicInteger、AtomicLong、AtomicReference 等。

public class CASTest {
    public static void main(String[] args) {
        
        DemoRunnable dr = new DemoRunnable();
        
        for (int i = 0; i < 10; i++) {
            new Thread(dr).start();
        }
    }
}
class DemoRunnable implements Runnable {
    private volatile AtomicInteger ai = new AtomicInteger();
    @Override
    public void run() {
        try {
            Thread.sleep(200);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("子线程-count:" + (ai.incrementAndGet()));
    }
}

不管是哪个线程最后结束,但是各个线程的累加结果不会重复,它是线程安全的
可能的结果1:

子线程-count:1
子线程-count:4
子线程-count:3
子线程-count:2
子线程-count:5
子线程-count:6
子线程-count:7
子线程-count:8
子线程-count:9
子线程-count:10

可能的结果2

子线程-count:1
子线程-count:6
子线程-count:5
子线程-count:4
子线程-count:3
子线程-count:2
子线程-count:7
子线程-count:8
子线程-count:9
子线程-count:10

源码分析

AtomicInteger源码分析

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

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

 public final native boolean compareAndSwapInt(Object var1, long var2, int var4,
 int var5);


通过声明一个volatile value(内存锁定,同一时刻只有一个线程可以修改内存值)类型的变量,再加上unsafe.compareAndSwapInt的方法,来保证实现线程同步的。
compareAndSet 传入的是执行方法时获取到的 value 属性值,next 为加 1 后的值,compareAndSet所做的为调用 Sun 的 UnSafe 的 compareAndSwapInt 方法来完成,此方法为 native 方法,compareAndSwapInt 基于的是CPU 的 CAS指令来实现的。所以基于 CAS 的操作可认为是无阻塞的,一个线程的失败或挂起不会引起其它线程也失败或挂起。并且由于 CAS 操作是 CPU 原语,所以性能比较好。


CAS的不足

ABA问题

所谓ABA问题就是指在更新前的值是A,但在操作过程中被其他线程更新为B,又更新为 A,这时当前线程认为是可以执行的,其实是发生了不一致现象,如果这种不一致对程序有影响(真正有这种影响的场景很少,除非是在变量操作过程中以此变量为标识位做一些其他的事,比如初始化配置),在这种情况下就要替修改加上版本号来做唯一的标示,采用初始值+版本号的联合比较法来判断,以此来避免ABA问题。

规避ABA问题可以使用AtomicStampedReference和AtomicMarkableReference这两个类。它们支持在两个变量上执行原子的条件更新。AtomicStampedReference更新一个“对象-引用”二元组,通过在引用上加上“版本号”规避。AtomicMarkableReference则更新一个“对象引用-布尔值”的二元组

CAS这种技术固然很好,但是在复杂的情况下不推荐使用,会带来ABA问题,也可能会因为大量线程的反复重试引起不必要的资源消耗,这样就有点得不偿失了。CAS这项技术适合在一些较为简单的,线程更新不频繁的场景中使用。在简单场景中,作为synchronized的替代品来保护某个变量的原子操作,是个不错的选择。

参考自 https://juejin.im/entry/5a5d8e686fb9a01c952616d3

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

推荐阅读更多精彩内容

  • 本文是我自己在秋招复习时的读书笔记,整理的知识点,也是为了防止忘记,尊重劳动成果,转载注明出处哦!如果你也喜欢,那...
    波波波先森阅读 11,231评论 4 56
  • 一、线程 1.1 线程的概述 一个运行程序就是一个进程,而线程是进程中独立运行的子任务 线程是操作系统执行流中的最...
    itcjj阅读 937评论 0 8
  • 简书 賈小強转载请注明原创出处,谢谢! 一个Java 5中最好的补充是对原子操作的支持类,如AtomicInteg...
    賈小強阅读 546评论 0 2
  • 灯光暗下来的时候,才知道心跳的频率是怎样的。放一首歌才能想起很多忽略很久的人和事。心里总是想着过着跟大家一样吧,一...
    张小圆子阅读 129评论 0 0
  • 秋天的树叶 当有一片栾树叶悠悠地落到了我的头上时,我的直觉告诉我:秋天来了! 秋天,是硕果累累;秋天,是丰富多彩;...
    土豆山药蛋阅读 188评论 0 1