ABA问题_乐观锁aba引发的实际问题
问题 引发 实际 乐观 ABA
2023-06-13 09:13:10 时间
大家好，又见面了，我是你们的朋友全栈君。
ABA问题
一.概述：
ABA问题是在多线程并发的情况下，发生的一种现象。上一次记录了有关CAS操作的一些知识，CAS通过比较内存中的一个数据是否是预期值，如果是就将它修改成新值，如果不是则进行自旋，重复比较的操作，直到某一刻内存值等于预期值再进行修改。而ABA问题则是在CAS操作中存在的一个经典问题，这个问题某些时候不会带来任何影响，某些时候却是影响很大的。
二.什么是ABA问题？
理解一： 当执行campare and swap会出现失败的情况。例如，一个线程先读取共享内存数据值A，随后因某种原因，线程暂时挂起，同时另一个线程临时将共享内存数据值先改为B，随后又改回为A。随后挂起线程恢复，并通过CAS比较，最终比较结果将会无变化。这样会通过检查，这就是ABA问题。 在CAS比较前会读取原始数据，随后进行原子CAS操作。这个间隙之间由于并发操作，最终可能会带来问题。 理解二
“ABA”问题：假设t1线程工作时间为10秒，t2线程工作时间为2秒，那么可能在A的工作期间，主内存中的共享变量 A已经被t2线程修改了多次，只是恰好最后一次修改的值是该变量的初始值，虽然用CAS判定出来的结果是期望值，但是却不是原来那个了=======》“狸猫换太子” 相当于是只关心共享变量的起始值和结束值，而不关心过程中共享变量是否被其他线程动过。 有些业务可能不需要关心中间过程，只要前后值一样就行，但是有些业务需求要求变量在中间过程不能被修改。
只靠CAS无法保证ABA问题，需要使用“原子引用”才能解决！！！！
三.ABA问题的解决：
原子引用：（存在ABA问题）
案列：
package InterviewTest;
import java.util.concurrent.atomic.AtomicReference;
class User{
String name;
int age;
public User(String name,int age) {
this.name=name;
this.age=age;
}
@Override
public String toString() {
return "User [name=" + name + ", age=" + age + "]";
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getAge() {
return age;
}
public void setAge(int age) {
this.age = age;
}
}
public class AtomicReferenceDemo {
public static void main(String[] args) {
User z3 = new User("z3",25);
User li4 = new User("li4",25);
AtomicReference<User> atomicReference = new AtomicReference<>();
atomicReference.set(z3);
System.out.println(atomicReference);
System.out.println(atomicReference.compareAndSet(z3, li4)+
" "+atomicReference.get().toString());
System.out.println(atomicReference.compareAndSet(li4, z3)+
" "+atomicReference.get().toString());
}
}带版本号的原子引用（解决ABA问题）
AtomicStampedReference版本号原子引用： 案例：两种原子引用的对比
package InterviewTest;
import java.util.concurrent.atomic.AtomicReference;
import java.util.concurrent.atomic.AtomicStampedReference;
public class ABADemo {
static AtomicReference<Integer> atomicReference
= new AtomicReference<>(100);
static AtomicStampedReference<Integer> atomicStampedReference
= new AtomicStampedReference<>(100,1);
public static void main(String[] args) {
System.out.println("************以下是ABA问题的产生**************");
new Thread(()->{
atomicReference.compareAndSet(100, 101);
atomicReference.compareAndSet(101, 100);
},"t1").start();
new Thread(()->{
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(atomicReference.compareAndSet(100, 2019)
+" "+atomicReference.get());
},"t2").start();
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("************以下是ABA问题的解决**************");
new Thread(()->{
int stamp = atomicStampedReference.getStamp();
System.out.println(Thread.currentThread().getName()
+" "+" 第一次版本号："+stamp);
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
atomicStampedReference.compareAndSet(100,
101,
atomicStampedReference.getStamp(),
atomicStampedReference.getStamp()+1);
System.out.println(Thread.currentThread().getName()
+" "+" 第2次版本号："+atomicStampedReference.getStamp());
atomicStampedReference.compareAndSet(101,
100,
atomicStampedReference.getStamp(),
atomicStampedReference.getStamp()+1);
System.out.println(Thread.currentThread().getName()
+" "+" 第3次版本号："+atomicStampedReference.getStamp());
},"t3").start();
new Thread(()->{
int stamp = atomicStampedReference.getStamp();
System.out.println(Thread.currentThread().getName()
+" "+" 第一次版本号："+stamp);
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
boolean result = atomicStampedReference.compareAndSet(
100,
2019,
stamp,
stamp+1);
System.out.println(Thread.currentThread().getName()+
" 修改成功否："+result+" 当前最新实际版本号："
+atomicStampedReference.getStamp());
System.out.println(Thread.currentThread().getName()+
" 当前实际最新值："
+atomicStampedReference.getReference());
},"t4").start();
}
}
************以下是ABA问题的产生**************
true 2019
************以下是ABA问题的解决**************
t3 第一次版本号：1
t4 第一次版本号：1
t3 第2次版本号：2
t3 第3次版本号：3
t4 修改成功否：false 当前最新实际版本号：3
t4 当前实际最新值：100版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
发布者：全栈程序员-用户IM，转载请注明出处：https://javaforall.cn/203708.html原文链接：https://javaforall.cn
相关文章
- 解决Tomcat闪退问题
- 挂钩 NtCreateThreadEx 导致 0xC00000F2 问题
- 一次TiDB GC阻塞引发的性能问题分析
- 【运筹学】对偶理论 : 互补松弛定理应用 ( 原问题与对偶问题标准形式 | 已知原问题最优解求对偶问题最优解 | 使用单纯形法求解 | 使用互补松弛定理公式一求解 | 互补松弛定理公式二无效 ) ★★
- 详解RedisTemplate下Redis分布式锁引发的系列问题
- http长链接处理不当引发的问题详解程序员
- linux No space left on device由索引节点(inode)爆满引发500问题
- POST请求乱码问题详解编程语言
- 研究警告许多COVID-19康复者面临长期认知与精神问题
- MySQL 不支持 GBK：引发的问题及解决办法（mysql不支持gbk）
- 重启Oracle数据库监听器：解决突破问题（重启oracle的监听器）
- 解决Linux系统下波特率设置问题（linux波特率设置）
- 解决Oracle密码修改问题：ALTER USER命令（oracle修改密码命令）
- 500错误：Linux服务器出现问题（linux错误500）
- 引发Oracle性能问题内存占用太多（oracle 内存太大）
- MySQL修改编码解决乱码问题（mysql 中修改编码）
- 线程冲突探究redis并发引发的问题（并发导致redis）
- 报错Oracle修改后触发器引发的报错问题（oracle修改后触发器）
- 深度解析解决Redis遇到的问题（redis问题分析）
- 导致的问题Redis连接过多引发的危害（redis 链接太多）
- 处理Redis重启引发的突发问题（redis重启问题）
- Oracle IO引发的问题及其解决方案（oracle io成问题）
- 利用Redis解决网站浏览量高峰问题（redis 解决浏览数量）
- 警惕由Redis缓存引发的性能问题（redis缓存过多）
- 这种蘑菇皮革不仅环保还能解决动物皮革引发的伦理问题
- asp读取utf-8格式文档并生成utf-8格式文档的乱码问题
- 一句话解决AJAX中文乱码问题[推荐]
- mysql启动的error2003和1067错误问题解决方法
- 不同Jquery版本引发的问题解决
- 为JS扩展Array.prototype.indexOf引发的问题及解决办法