目录
" >通过AtomicMarkableReference解决ABA问题
首页 Java Java面试题 面试官问你:你知道什么是ABA问题吗?

面试官问你:你知道什么是ABA问题吗?

Jul 26, 2023 pm 03:09 PM
cas

狸猫换太子

在开始问题的阐述之前,我们先来看一则小故事:

北宋宋真宗皇后死后,当时他的两位爱妃刘妃和李妃都怀了孕,很显然,谁生了儿子,谁就有可能立为正宫。刘妃久怀嫉妒之心,唯恐李妃生了儿子被立为皇后,于是与宫中总管都堂郭槐定计,在接生婆尤氏的配合下,乘李妃分娩时由于血晕而人事不知之机,将一狸猫剥去皮毛,血淋淋,光油油地换走了刚出世的太子。刘妃命宫女寇珠勒死太子,寇珠于心不忍,暗中将太子交付宦官陈琳,陈琳将太子装在提盒中送至八贤王处抚养。再说真宗看到被剥了皮的狸猫,以为李妃产下了一个妖物,乃将其贬入冷宫。不久,刘妃临产,生了个儿子,被立为太子,刘妃也被册立为皇后。谁知六年后,刘后之子病夭。真宗再无子嗣,就将其皇兄八贤王之子(实为当年被换走的皇子)收为义子,并立为太子。

从这故事看出来,太子出生被被换成了狸猫,最后阴差阳错又回归成为太子。虽然结果是一样的,但是过程曲折了,太子真的是命途多舛啊。

为什么说这个故事?其实跟我们今天要介绍的问题有很大的关系。同样的结果,可能中间不知道发生了多少次操作,那么我们能认为他没变吗?在不同的业务场景下,我们要仔细考虑这个问题。

ABA问题描述

在多线程场景下CAS会出现ABA问题,关于ABA问题这里简单科普下,例如有2个线程同时对同一个值(初始值为A)进行CAS操作,这三个线程如下:

  1. 线程1,期望值为A,欲更新的值为B
  2. 线程2,期望值为A,欲更新的值为B

线程1抢先获得CPU时间片,而线程2因为其他原因阻塞了,线程1取值与期望的A值比较,发现相等然后将值更新为B,然后这个时候出现了线程3,期望值为B,欲更新的值为A,线程3取值与期望的值B比较,发现相等则将值更新为A,此时线程2从阻塞中恢复,并且获得了CPU时间片,这时候线程2取值与期望的值A比较,发现相等则将值更新为B,虽然线程2也完成了操作,但是线程2并不知道值已经经过了A->B->A的变化过程。

举个具体的例子说明

小明在提款机,提取了50元,因为提款机问题,有两个线程,同时把余额从100变为50:

  • 线程1(提款机):获取当前值100,期望更新为50;
  • 线程2(提款机):获取当前值100,期望更新为50;
  • 线程1成功执行,线程2某种原因block了;
  • 这时,某人给小明汇款50;
  • 线程3(默认):获取当前值50,期望更新为100,这时候线程3成功执行,余额变为100;
  • 线程2从Block中恢复,获取到的也是100,compare之后,继续更新余额为50。

此时可以看到,实际余额应该为100(100-50+50),但是实际上变为了50(100-50+50-50)这就是ABA问题带来错误提交结果。

解决方法

要解决ABA问题,可以增加一个版本号,当内存位置V的值每次被修改后,版本号都加1

代码示例

通过AtomicStampedReference来解决ABA问题

  • AtomicStampedReference内部维护了对象值和版本号,在创建AtomicStampedReference对象时,需要传入初始值和初始版本号;

  • 当AtomicStampedReference设置对象值时,对象值以及状态戳都必须满足期望值,写入才会成功。

private static AtomicStampedReference<Integer> atomicStampedReference = new AtomicStampedReference<Integer>(100,1);

public static void main(String[] args) {
//第一个线程
 new Thread(() -> {
  System.out.println("t1拿到的初始版本号:" + atomicStampedReference.getStamp());
  
  //睡眠1秒,是为了让t2线程也拿到同样的初始版本号
  try {
   TimeUnit.SECONDS.sleep(1);
  } catch (InterruptedException e) {
   e.printStackTrace();
  }
  atomicStampedReference.compareAndSet(100, 101,atomicStampedReference.getStamp(),atomicStampedReference.getStamp()+1);
  atomicStampedReference.compareAndSet(101, 100,atomicStampedReference.getStamp(),atomicStampedReference.getStamp()+1);
 },"t1").start();
 
  // 第二个线程
 new Thread(() -> {
  int stamp = atomicStampedReference.getStamp();
  System.out.println("t2拿到的初始版本号:" + stamp);
  
  //睡眠3秒,是为了让t1线程完成ABA操作
  try {
   TimeUnit.SECONDS.sleep(3);
  } catch (InterruptedException e) {
   e.printStackTrace();
  }
  System.out.println("最新版本号:" + atomicStampedReference.getStamp());
  System.out.println(atomicStampedReference.compareAndSet(100, 2019,stamp,atomicStampedReference.getStamp() + 1) + "\t当前值:" + atomicStampedReference.getReference());
 },"t2").start();
}
登录后复制

1、初始值100,初始版本号1
2、线程t1和t2拿到一样的初始版本号
3、线程t1完成ABA操作,版本号递增到3
4、线程t2完成CAS操作,最新版本号已经变成3,跟线程t2之前拿到的版本号1不相等,操作失败

执行结果:

t1拿到的初始版本号:1
t2拿到的初始版本号:1
最新版本号:3
false 当前值:100
登录后复制

通过AtomicMarkableReference解决ABA问题

AtomicStampedReference可以给引用加上版本号,追踪引用的整个变化过程,如:A -> B -> C -> D -> A,通过AtomicStampedReference,我们可以知道,引用变量中途被更改了3次。但是,有时候,我们并不关心引用变量更改了几次,只是单纯的关心是否更改过,所以就有了AtomicMarkableReference, AtomicMarkableReference的唯一区别就是不再用int标识引用,而是使用boolean变量——表示引用变量是否被更改过。

private static AtomicMarkableReference<Integer> atomicMarkableReference = new AtomicMarkableReference<Integer>(100,false);

public static void main(String[] args) {
// 第一个线程
 new Thread(() -> {
  System.out.println("t1版本号是否被更改:" + atomicMarkableReference.isMarked());
  
  //睡眠1秒,是为了让t2线程也拿到同样的初始版本号
  try {
   TimeUnit.SECONDS.sleep(1);
  } catch (InterruptedException e) {
   e.printStackTrace();
  }
  atomicMarkableReference.compareAndSet(100, 101,atomicMarkableReference.isMarked(),true);
  atomicMarkableReference.compareAndSet(101, 100,atomicMarkableReference.isMarked(),true);
 },"t1").start();
 
  // 第二个线程
 new Thread(() -> {
  boolean isMarked = atomicMarkableReference.isMarked();
  System.out.println("t2版本号是否被更改:" + isMarked);
  
  //睡眠3秒,是为了让t1线程完成ABA操作
  try {
   TimeUnit.SECONDS.sleep(3);
  } catch (InterruptedException e) {
   e.printStackTrace();
  }
  System.out.println("是否更改过:" + atomicMarkableReference.isMarked());
  System.out.println(atomicMarkableReference.compareAndSet(100, 2019,isMarked,true) + "\t当前值:" + atomicMarkableReference.getReference());
 },"t2").start();
}
登录后复制

1、初始值100,初始版本号未被修改 false
2、线程t1和t2拿到一样的初始版本号都未被修改 false
3、线程t1完成ABA操作,版本号被修改 true
4、线程t2完成CAS操作,版本号已经变成true,跟线程t2之前拿到的版本号false不相等,操作失败

执行结果:

t1版本号是否被更改:false
t2版本号是否被更改:false
是否更改过:true
false 当前值:100
登录后复制

多说几句

以上是本期关于CAS领域的一个经典ABA问题的解析,不知道你在实际的工作中有没有遇到过,但是在面试中这块是并发知识考查的重点。如果你还没接触过此类的问题,我的建议是你自己将上面的代码运行一下,结合理论去理解一下ABA问题所带来的问题以及如何解决他,这对你日后的开发工作也是有莫大的帮助的!

以上是面试官问你:你知道什么是ABA问题吗?的详细内容。更多信息请关注PHP中文网其他相关文章!

本站声明
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智能驱动的应用程序,用于创建逼真的裸体照片

AI Clothes Remover

AI Clothes Remover

用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool

Undress AI Tool

免费脱衣服图片

Clothoff.io

Clothoff.io

AI脱衣机

AI Hentai Generator

AI Hentai Generator

免费生成ai无尽的。

热门文章

R.E.P.O.能量晶体解释及其做什么(黄色晶体)
4 周前 By 尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.最佳图形设置
4 周前 By 尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.如果您听不到任何人,如何修复音频
1 个月前 By 尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.聊天命令以及如何使用它们
1 个月前 By 尊渡假赌尊渡假赌尊渡假赌

热工具

记事本++7.3.1

记事本++7.3.1

好用且免费的代码编辑器

SublimeText3汉化版

SublimeText3汉化版

中文版,非常好用

禅工作室 13.0.1

禅工作室 13.0.1

功能强大的PHP集成开发环境

Dreamweaver CS6

Dreamweaver CS6

视觉化网页开发工具

SublimeText3 Mac版

SublimeText3 Mac版

神级代码编辑软件(SublimeText3)

通过 CAS(Central Authentication Service) 实现 PHP 安全验证 通过 CAS(Central Authentication Service) 实现 PHP 安全验证 Jul 24, 2023 pm 12:49 PM

通过CAS(CentralAuthenticationService)实现PHP安全验证随着互联网的快速发展,用户权限管理和身份验证越来越重要。在开发WEB应用程序时,保护用户数据和防止未经授权访问是至关重要的。为了实现这一目标,我们可以使用CAS(CentralAuthenticationService)来进行PHP的安全验证。CAS

java CAS的概念是什么 java CAS的概念是什么 May 03, 2023 pm 09:34 PM

1、说明当多个线程同时对某个资源进行CAS操作时,只有一个线程成功,但不会堵塞其他线程,其他线程只会收到操作失败的信号。可见CAS其实是一个乐观的锁。2、实例跟随AtomInteger的代码,我们可以发现最终调用的是sum.misc.Unsafe。看看Unsafe这个名字,它是一个不安全的类别,它利用了Java类别和可见性规则中恰到好处的漏洞。为了速度,Unsafe在Java的安全标准上做出了一些妥协。publicfinalnativebooleancompareAndSwapInt(Objec

CAS与java乐观锁怎么用 CAS与java乐观锁怎么用 May 01, 2023 pm 08:07 PM

什么是CASCAS是CompareAndSwap,即比较和交换。为什么CAS没有用到锁还能保证并发情况下安全的操作数据呢,名字其实非常直观的表明了CAS的原理,具体修改数据过程如下:用CAS操作数据时,将数据原始值和要修改的值一并传递给方法比较当前目标变量值与传进去的原始值是否相同如果相同,表示目标变量没有被其他线程修改,直接修改目标变量值即可如果目标变量值与原始值不同,那么证明目标变量已经被其他线程修改过,本次CAS修改失败从上述过程可以看到CAS其实保证的是安全的修改数据,但是修改存在失败的

java的CAS怎么应用 java的CAS怎么应用 Apr 18, 2023 pm 06:37 PM

CAS解释:CAS(compareandswap),比较并交换。可以解决多线程并行情况下使用锁造成性能损耗的一种机制.CAS操作包含三个操作数—内存位置(V)、预期原值(A)和新值(B)。如果内存位置的值与预期原值相匹配,那么处理器会自动将该位置值更新为新值。否则,处理器不做任何操作。一个线程从主内存中得到num值,并对num进行操作,写入值的时候,线程会把第一次取到的num值和主内存中num值进行比较,如果相等,就会将改变后的num写入主内存,如果不相等,则一直循环对比,知道成功为止。CAS产

Java有锁并发、无锁并发和CAS实例分析 Java有锁并发、无锁并发和CAS实例分析 May 23, 2023 pm 01:34 PM

有锁并发对于大多数程序员(当然我也基本上是其中一员),并发编程几乎就等价于给相关数据结构加上一个锁(Mutex)。比如如果我们需要一个支持并发的栈,那最简单的方法就是给一个单线程的栈加上锁std::sync::Mutex。(加上Arc是为了能让多个线程都拥有栈的所有权)usestd::sync::{Mutex,Arc};#[derive(Clone)]structConcurrentStack{inner:Arc,}implConcurrentStack{pubfnnew()->Self{

面试真题:请你聊聊并发中的CAS 机制 面试真题:请你聊聊并发中的CAS 机制 Jul 26, 2023 pm 03:05 PM

程序中,我创建了100个线程,每个线程中对共享变量inc进行累加10000次的操作,如果是同步执行的话,inc最终的值应该是1000000,但我们知道在多线程中,程序是并发执行的,也就是说不同的线程可能会同时读取到主内存相同的值

基于springboot怎么搭建CAS Client客户端 基于springboot怎么搭建CAS Client客户端 May 14, 2023 am 10:46 AM

1.新建springboot项目并引入依赖org.jasig.cas.clientcas-client-support-springboot3.6.22.配置@EnableCasClient注解packagecom.codetiler.demo;importorg.jasig.cas.client.boot.configuration.EnableCasClient;importorg.springframework.boot.SpringApplication;importorg.spring

面试官问你:你知道什么是ABA问题吗? 面试官问你:你知道什么是ABA问题吗? Jul 26, 2023 pm 03:09 PM

本期关于CAS领域的一个经典ABA问题的解析,不知道你在实际的工作中有没有遇到过,但是在面试中这块是并发知识考查的重点。如果你还没接触过此类的问题,我的建议是你自己将上面的代码运行一下

See all articles