Java-CAS

原子性操作

原子即为不可再分的,原子操作即要么所有操作全部完成 要么全不完成
用synchronized包围的代码块或方法就是原子操作。对于线程来讲,synchronized包围代码,只会全部完成,不会执行一半而中断。
synchronized是一个很重的操作,如果执行代码很简单,例如i++,很多线程都阻塞在外面很划不来,为了解决这种问题,引出了CAS(Compare And Swap),比较并且交换。系统提供了很多原子变量,Atomic开头的变量都是实现了CAS,例如AtomicBoolean、AtomicInteger等。

CAS

CAS原理

我们下面举个例子:
假如我们现在有多个线程执行count++这个操作。

CASCount.jpg
  1. 首先从内存中取出count的值。(假如这时是0)
  2. 然后进行累加操作。(count变为了1)
  3. 这时在从内存中取出count的值,如果与第一步取到的值相等,则将累加操作后的值写入内存,否则 说明有别的线程改过了,这时再重复第一步操作,直到完成赋值操作。

总结:
获取内存中的值 ,进行操作,再写入内存的时候,进行判断当前内存中的值是否与之前取出的值是否一致,不一致的话以内存中的新值,重新计算,反复执行(自旋,其实就是死循环),直到内存中的值没有在经过修改,才进行写入操作。

这里就引出了两个概念:

  • 悲观锁 先锁再操作(synchronized)
  • 乐观锁 先操作再判断是否进行修改

CAS和synchronized性能比较:
正常生产环境下CAS的效率是要高于synchronized,因为synchronized会阻塞线程,线程阻塞的时候会发生上下文切换(3-5ms),CAS执行指令的时间大概在0.6ns。
高度竞争,特意设计的情况下synchronized会优于CAS。

为什么有CAS还需要synchronized

  • ABA问题:
    假设当前有两个线程ThreadA和ThreadB,一个变量A
    ThreadA想把A修改为B,根据上面介绍的CAS原理,我们知道,修改的时候会判断A是否被修改过,用段伪代码表示也就是if(A==A) A = B
    ThreadB比ThreadA跑的快,ThreadA把A修改为C,然后又改回为A。
    可是ThreadA认为A没被修改过。

解决办法:版本戳 要求每个线程修改值的时候 加入一个版本戳
jdk中提供了相关的操作
AtomicMarkReference(有没有变过) AtomicStampedReference(变了几次)

public class UserAtomicMarkable {
    static AtomicStampedReference<String> atomicStampedReference = new AtomicStampedReference<>("red",0);

    public static void main(String[] args) throws InterruptedException {
        final int oldStamp = atomicStampedReference.getStamp();
        final String oldReference = atomicStampedReference.getReference();
        System.out.println(oldReference + "----------" + oldStamp);

         Thread  threadA = new Thread(){
            @Override
            public void run() {
                super.run();
                System.out.println(Thread.currentThread().getName() + "当前变量值 " + oldReference + "-当前版本戳 " + oldStamp );
                atomicStampedReference.compareAndSet(oldReference,oldReference + "Java",oldStamp,oldStamp + 1);
            }
        };

        Thread  threadB = new Thread(){
            @Override
            public void run() {
                super.run();
                String reference = atomicStampedReference.getReference();
                int stamp = atomicStampedReference.getStamp();
                System.out.println(Thread.currentThread().getName() + "当前变量值 " + reference + "-当前版本戳 " + stamp );
                atomicStampedReference.compareAndSet(reference,reference + "C",stamp,stamp + 1);
                String reference1 = atomicStampedReference.getReference();
                int stamp1 = atomicStampedReference.getStamp();
                System.out.println(Thread.currentThread().getName() + "当前变量值 " + reference1 + "-当前版本戳 " + stamp1 );
            }
        };

        threadA.start();
        threadA.join();
        threadB.start();
        threadB.join();

        System.out.println(atomicStampedReference.getReference() + "----------" + atomicStampedReference.getStamp());
    }

}
  • 开销问题
    当竞争激烈的时候,会存在长时间完成不了操作 ,造成自旋,一直重试,会占用CPU资源。
    解决办法:换成synchronized。

  • 只能保证一个共享变量的原子操作
    CAS操作时,只能针对某个内存地址上的值进行修改,而一个地址往往只能保存一个变量。
    解决办法:AtomicReference把多个变量打包到一个对象中 替换对象

public class UseAtomicReference {
    static AtomicReference<User> atomicReference;

    public static void main(String[] args) {
        User user = new User("xiaoming",22);
        atomicReference = new AtomicReference<>(user);
        User updateUser = new User("xiaohong",16);
        atomicReference.compareAndSet(user,updateUser);

        System.out.println(atomicReference.get());
        System.out.println(user);
    }

    static class User{
        private String name;
        private int age;

        public User(String name, int age) {
            this.name = name;
            this.age = age;
        }

        public String getName() {
            return name;
        }

        public int getAge() {
            return age;
        }

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