java吧_死磕好不好

java吧_死磕好不好死磕Java——CAS

大家好,又见面了,我是你们的朋友全栈君。

一、死磕Java——CAS

前面我们说到volatile不保证原子性,解决办法就是使用AtomicInteger代替int,但是为什么使用AtomicInteger就可以保证了原子性了,是因为AtomicInteger实现的就是CAS思想Unsafe的支持。

1.1.CAS是什么

AtomicInteger atomicInteger = new AtomicInteger(5);
atomicInteger.compareAndSet(5, 10);
复制代码

CAS:即比较和交换(compareAndSet),CAS的思想比较简单就是三个值:当前内存值V,旧的预期值A,和要更新的值B,当且仅当内存值V等于预期值A,才将内存值修改为B,并返回true,否则什么都不做,返回false。下面就以atomicInteger.getAndIncrement();分析一下AtomicInteger使用的CAS思想。

1.2.CAS的原理

使用AtomicInteger

public static void main(String[] args) {
    AtomicInteger atomicInteger = new AtomicInteger(5);
    atomicInteger.compareAndSet(5, 10);
    atomicInteger.getAndIncrement();
}
复制代码

compareAndSet方法

public final int getAndIncrement() {
    return unsafe.getAndAddInt(this, valueOffset, 1);
}
复制代码

unsafe.getAndAddInt(this, valueOffset, 1)说明:

  • this:代表当前对象,这里就是外部newatomicInteger对象;
  • valueOffset:代表当前对象的内存地址。
  • 1:就是加1。
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); }
}

private volatile int value;
复制代码

说明:

上述代码就是根据对象的内存地址获取当前内存的值,注意的是private volatile int value;添加了volatile关键字,所以,保证了可见性。

unsafe.getAndAddInt方法

public final int getAndAddInt(Object var1, long var2, int var4) {
    int var5;
    do {
        var5 = this.getIntVolatile(var1, var2);
    } while(!this.compareAndSwapInt(var1, var2, var5, var5 + var4));

    return var5;
}
复制代码

说明:

  • unsafe类是CAS的核心类,由于Java无法直接操作底层系统,只能通过native修饰的本地方法操作,基于unsafe类就可以直接操作内存中的数据。
  • getAndAddInt(Object var1, long var2, int var4)中:Object var1:当前对象,long var2:当前对象的内存地址,int var4:需要更新的值,这里就是1。
  • var5 = this.getIntVolatile(var1, var2);:就是取到当前对象的内存值;
  • 假如现在存在两个线程,跑在不同的cpu上,内存中atomicInteger的原始值为5,两个线程都拷贝一份到自己的工作内存中,
  • 线程A通过getIntVolatile(var1, var2)拿到value值5,这时线程A被挂起。
  • 线程B也通过getIntVolatile(var1, var2)方法获取到value值5,线程B没有被挂起,并执行compareAndSwapInt方法比较内存值也为5,成功修改内存值为10。
  • 这时线程A恢复,执行compareAndSwapInt方法比较,发现自己手里的值(5)和内存的值(10)不一致,说明该值已经被其它线程提前修改过了,那只能重新来一遍了。
  • 重新获取value值,因为变量valuevolatile修饰,所以其它线程对它的修改,线程A总是能够看到,线程A继续执行compareAndSwapInt进行比较替换,直到成功。

1.3.CAS的缺点

前面的代码分析中我们知道getAndAddInt方法有一个do-while循环,如果CAS失败,就会进行一直尝试比较,如果很长时间都不成功,就会增加CPU的开销。所以CAS的一个缺点就是循环时间长开销大,由于this表示的是当前对象,所以,存在另外一个缺点就是只能保证一个共享变量的原子操作。最重要的缺点就是ABA问题

1.3.1.什么是ABA问题

前面分析CAS思想的时候,我们知道一个线程会先获取Value的值,比较和交换的时候再获取内存的值和手里的value进行比较,说的是如果一致就表示没有被其他线程修改过,然后就执行自己的交换操作,但是,如果,一个线程修改了,然后另外还有一个线程又修改会原来的值,这个时候一比较还是一样的,这就是ABA问题。简单讲就是狸猫换太子。如果业务中不关心中间操作,只在乎开始和结尾是否一致就可,就不必要解决ABA 问题。

1.3.2.使用原子引用和版本机制解决ABA问题

java.util.concurrent.atomic包下存在一个AtomicReference类,就是原子引用,CAS比较的只是内存中的值,现在增加一个版本号,比较值的同时再比较版本后是否一致。使用AtomicStampedReference带时间戳的原子引用来解决ABA问题。

 public static void main(String[] args) {
        AtomicStampedReference<Integer> reference = new AtomicStampedReference<>(10, 1);

        new Thread(() -> {
            int stamp = reference.getStamp();
            System.out.println("T1拿到的第一次的版本号:" + stamp);
            // 先暂停1秒,等T2线程拿到相同的初始版本号
            try {
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            reference.compareAndSet(10, 101, reference.getStamp(), reference.getStamp() + 1);
            System.out.println("T1线程第一次操作后的版本号为:"  + reference.getStamp());
            reference.compareAndSet(101, 10, reference.getStamp(), reference.getStamp() + 1);
            System.out.println("T1线程第二次操作后的版本号为:"  + reference.getStamp());
        }, "T1").start();

        new Thread(() -> {
            int stamp = reference.getStamp();
            System.out.println("T2拿到的第一次的版本号:" + stamp);
            // 先暂停3秒,等T1线程有充分的时候做一次ABA操作
            try {
                TimeUnit.SECONDS.sleep(3);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            boolean b = reference.compareAndSet(10, 2019, stamp, stamp + 1);
            System.out.println("当前内存中的最新值为:" + reference.getReference());
            System.out.println("T2线程在T1线程执行完ABA问题后在执行的结果为:" + b);
        }, "T2").start();

    }
复制代码
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/106832.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • Spring Boot定制首页和404页面

    Spring Boot定制首页和404页面一、定制首页:方式一:SpringBoot自动映射在静态资源目录resources、static、public的其中一个目录中创建index.html文件,springBoot会自动识别,将这个文件作为首页访问 方式二:使用thymeleaf模板引擎1.导入依赖<!–Thymeleaf模板引擎依赖–><dependency><groupId>org.thymeleaf</groupId><artifact

  • HTTP-500错误的常见原因与分析「建议收藏」

    HTTP-500错误的常见原因与分析「建议收藏」前言:最近使用阿里云windows2008R2云服务器搭建网站QQ互联接入(第三方登录)服务的过程中,使用了phpcmsV9提供的V9.6.3压缩包内的.htaccess文件。几经辗转,仍然没能解决过程中遇到的问题,问了一些技术大咖,有人说可能是500错误。以前知道有400报错,还真不知道有个500错误,所以上网查询之后,觉得应该小结一篇。1.造成500错误常见原因有:ASP语法出…

  • mysql查看数据库的日志文件_怎么查看mysql数据库的日志文件「建议收藏」

    mysql查看数据库的日志文件_怎么查看mysql数据库的日志文件「建议收藏」2017-10-16回答一.错误日志错误日志在mysql数据库中很重要,它记录着mysqld启动和停止,以及服务器在运行过程中发生的任何错误的相关信息。1.配置信息–log-error=[file-name]用来指定错误日志存放的位置。如果没有指定[file-name],默认hostname.err做为文件名,默认存放在datadir目录中。也可以将log-error配置到my.cnf文件中,…

    2022年10月14日
  • 2019/6/18

    今日内容:1.selenium剩余用法2.selenium万能登录破解3.破解极验滑动验证码fromseleniumimportwebdriverimporttimedriver=webdriver.Chrome(r’D:BaiduNetdiskDownload(chromedriver_win32chr…

  • java文档注释符号_java的注释符号

    java文档注释符号_java的注释符号1JAVA语法基础1.1标识符标识符可以简单的理解成一个名字。在Java中,我们需要标识代码的很多元素,包括类名、方法、字段、变量、包名等等。我们选择的那个名称就称为标识符,一个正确的标识符需要遵循以下规则:1.标识符可以由字母、数字、下划线(_)、美元符($)组成,但不能包含@、%、空格等其它特殊字符2.不能以数字开头。如:123name就是不合法3.标识符严格区分大小写。如:tmooc和tMooc是两个不同的标识符4.标识符的命名最好能反映出其作用,做到见名知意。

  • mybatis中调用存储过程_java如何调用存储过程

    mybatis中调用存储过程_java如何调用存储过程项目结构数据表t_user创建Userpackagecom.po;publicclassUser{ privateIntegerid; privateStringname; privateStringsex; privateIntegerage; publicIntegergetId(){ returnid; } publi…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号