当前位置: 首页 > article >正文

【JUC】12-CAS

1. CAS

compare and swap,比较并交换。

包含三个操作数:内存位置、预期原值及更新值。

执行CAS操作的时候,将内存位置的值与预期原值比较:

  • 匹配,更新为新值。
  • 不匹配,不进行操作,多个线程同时执行CAS操作只有一个会成功。

CAS是JDK提供的非阻塞原子性操作,通过硬件保证比较-更新的原子性。底层实现为CPU指令cmpxchg,效率更高。通过unsafe类实现。

2. 自旋

线程修改失败重试的过程叫自旋。

public static void main(String[] args) {
        AtomicInteger integer = new AtomicInteger(5);
        System.out.println(integer.compareAndSet(51, 200) + " " + integer.get());
    }

在这里插入图片描述
自旋的实现代码
在这里插入图片描述
自己实现一个CAS。

public class SingletonLock {
    AtomicReference<Thread> atomicThread = new AtomicReference<>();
    public void Lock() {
        Thread thread = Thread.currentThread();
        System.out.println(thread.getName() + "Lock");
        // 当前不为空, 需要进行自旋
        while (!atomicThread.compareAndSet(null, thread)) {
        }
    }
    public void unLock() {
        Thread thread = Thread.currentThread();
        System.out.println(thread.getName() + "unLock");
        atomicThread.compareAndSet(thread, null);
    }
    public static void main(String[] args) {
        SingletonLock singletonLock = new SingletonLock();

        new Thread(()->{
            singletonLock.Lock();
            try {
                TimeUnit.SECONDS.sleep(2);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
            singletonLock.unLock();
        }, "t1").start();

        try {
            TimeUnit.MILLISECONDS.sleep(200);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
        new Thread(()->{
            singletonLock.Lock();
            singletonLock.unLock();
        }, "t2").start();
    }
}

3. AtomicReference包装类

class Stu {
    String name;
    Integer age;
    public Stu(String name, Integer age) {
        this.name = name;
        this.age = age;
    }
    @Override
    public String toString() {
        return name + ": " + age;
    }
}

public class demo03 {
    public static void main(String[] args) {
        Stu zs = new Stu("zs", 18);
        Stu ls = new Stu("ls", 29);

        AtomicReference<Stu> atomicReference = new AtomicReference<>();
        atomicReference.set(zs);
        System.out.println(atomicReference.compareAndSet(zs, ls) + " " + atomicReference.get().toString());
    }
}

4. CAS缺点

4.1 循环时间长,开销大

4.2 ABA问题

解决方案:版本号,戳记流水。
在这里插入图片描述

class Stus {
    Integer id;
    String name;
    public Stus(Integer id, String name) {
        this.id = id;
        this.name = name;
    }
    public String getName() {
        return name;
    }
}
public class demo04 {
    public static void main(String[] args) {
        Stus zs = new Stus(1, "zs");
        Stus ls = new Stus(2, "ls");
        AtomicStampedReference<Stus> atomicStampedReference = new AtomicStampedReference<>(zs, 1);
        atomicStampedReference.compareAndSet(zs, ls, atomicStampedReference.getStamp(), 2);
        System.out.println(atomicStampedReference.getReference().getName());
        atomicStampedReference.compareAndSet(ls,zs, atomicStampedReference.getStamp(), 3);
        System.out.println(atomicStampedReference.getReference().getName());
    }
}

http://www.kler.cn/a/290947.html

相关文章:

  • iClient3D for Cesium 实现限高分析
  • BlueLM:以2.6万亿token铸就7B参数超大规模语言模型
  • 渗透测试-前端加密分析之RSA加密登录(密钥来源服务器)
  • Go 语言常量
  • winform中屏蔽双击最大化或最小化窗体(C#实现),禁用任务管理器结束程序,在需要屏蔽双击窗体最大化、最小化、关闭
  • 行政管理痛点解决方案:OA系统助力企业提效减负
  • Nordic Collegiate Programming ContestNCPC 2021
  • Linux基础 -- 获取CPU负载信息
  • 在react 中还有另外一种three.js 渲染方式
  • 生活因科技而美好:一键解锁PDF处理的无限可能
  • 算法打卡 Day29(回溯算法)-复原 IP 地址 + 子集 + 子集 Ⅱ
  • Gin框架中的全局中间件与中间件传值
  • IDEA 安装lombok插件不兼容的问题及解决方法
  • 【弱监督时间动作定位】Probabilistic Vision-Language Representation for WSTAL 论文阅读
  • Linux shell调试:高效定位错误提高脚本可靠性
  • 修改SpringBoot启动图标banner
  • 使用AI写WebSocket知识是一种怎么样的体验?
  • 17. 如何决定使用ArrayList或LinkedList?在什么情况下选择其中之一?
  • 【Linux】进程周边:进程概念
  • RabbitMQ 入门:基本概念、特性及简单示例
  • 职场关系课:辞退下属的行动指南
  • 智能医学(二)——MDPI特刊推荐
  • HarmonyOS开发实战( Beta5.0)自定义组件冻结功能规范
  • flowable 国产数据库并发性能优化
  • Linux 学习之路 - 信号的保存
  • BUUCTF Crypto wp--RSA1