0

0

CAS与java乐观锁怎么用

王林

王林

发布时间:2023-05-01 20:07:16

|

1364人浏览过

|

来源于亿速云

转载

什么是cas

cas是compareandswap,即比较和交换。为什么cas没有用到锁还能保证并发情况下安全的操作数据呢,名字其实非常直观的表明了cas的原理,具体修改数据过程如下:

  1. 用CAS操作数据时,将数据原始值和要修改的值一并传递给方法

  2. 比较当前目标变量值与传进去的原始值是否相同

  3. 如果相同,表示目标变量没有被其他线程修改,直接修改目标变量值即可

  4. 如果目标变量值与原始值不同,那么证明目标变量已经被其他线程修改过,本次CAS修改失败

    立即学习Java免费学习笔记(深入)”;

从上述过程可以看到CAS其实保证的是安全的修改数据,但是修改存在失败的可能性,即目标变量数据修改不成功,这个时候我们要循环判断CAS修改数据结果,如果失败进行重试。

思维比较缜密的同学可能担心CAS本身这个比较与替换的操作产生并发安全问题,实际应用中这种情况不会发生,比较与替换由JDK借助硬件级别的CAS原语来保证比较替换是一个原子性动作。

CAS实现无锁编程

无锁编程指的是在不使用锁的情况下保证安全的操作共享变量在并发编程中,我们用各种锁来保证共享变量的安全性。即在保证一个线程未操作完共享变量的时候其他线程不能操作同一共享变量。
正确的使用锁可以保证并发情况下数据安全,但是在并发程度不高,竞争不激烈的时候,获取锁和释放锁就成了没必要的性能浪费。这种情况下可以可考虑利用CAS保证数据安全,实现无锁编程 

ONLYOFFICE
ONLYOFFICE

用ONLYOFFICE管理你的网络私人办公室

下载

头疼的ABA问题

上面我们已经了解了CAS保证安全操作共享变量的原理,但是上述CAS操作还存在缺陷。假设当前线程访问的共享变量值为A,在线程1访问共享变量过程中,线程2操作共享变量将其赋值为B,线程2处理完自己的逻辑后又将共享变量赋值为A。这时线程1比较共享变量值A与原始值A相同,误以为没有其他线程操作共享变量,直接返回操作成功。这就是ABA问题。虽然大部分业务不需要关心共享变量是否有过其他更改,只要原始值与当前值一致就能得到正确的结果,但是有一些敏感场景不光要考虑共享变量结果上等同于没有被修改过,同时也不能接受共享变量过程上被其他线程修改过。幸运的是ABA问题也有成熟的解决方案,我们为共享变量添加一个版本号,每当共享变量被修改这个版本号值就会自增。在CAS操作中我们比较的不是原始变量值,而是共享变量的版本号。每次操作共享变量更新的版本号都是唯一的,所以能够避免ABA问题。 

具体应用场景 

JDK中的CAS应用

首先多个线程对普通变量进行并发操作是不安全的,一个线程的操作结果可能被其他线程覆盖掉,比如现在我们用两个线程,每个线程将初始值为1的共享变量增加一,如果没有同步机制的话共享变量结果很可能小于3。即可能线程1和线程2都读到了初始值1,线程1将其赋值为2,线程2所在内存读取到的值还是1不会变,线程2也将变量增加1然后赋值成2,这样最终结果是2小于预期结果3。自增操作不是原子性操作导致了这个共享变量操作不安全问题。为了解决这个问题,JDK提供了一系列原子类提供相应的原子操作。下面是AtomicInteger中的getAndIncrement方法源码,让我们从源码来看是怎么利用CAS实现线程安全的原子性的整形变量相加操作。

/**
* 原子性的将当前值增加1
*
* @return 返回自增前的值
*/
public final int getAndIncrement() {
return unsafe.getAndAddInt(this, valueOffset, 1);
}
 

可以看到getAndIncrement实际调用了UnSafe类的getAndAddInt方法实现原子操作,下面是getAndAddInt源代码

/**
* 原子的将给定值与目标字变量相加并重新赋值给目标变量
*
* @param o 要更新的变量所在的对象
* @param offset 变量字段的内存偏移值
* @param delta 要增加的数字值
* @return 更改前的原始值
* @since 1.8
*/
public final int getAndAddInt(Object o, long offset, int delta) {
int v;
do {
// 获取当前目标目标变量值
v = getIntVolatile(o, offset);
// 这句代码是关键, 自旋保证相加操作一定成功
// 如果不成功继续运行上一句代码, 获取被其他
// 线程抢先修改的变量值, 在新值基础上尝试相加
// 操作, 保证了相加操作的原子性
} while (!compareAndSwapInt(o, offset, v, v + delta));
return v;
}
 

我们都对锁很熟悉, 比如可重入锁ReentrantLock, JDK提供的各种锁基本都依赖AbstractQueuedSynchronizer这个类, 当多个线程尝试获取锁时会进入一个队列等待, 其中多线程入队操作的原子性就是用CAS来保证的. 源代码如下:

/**
* 锁底层等待获取锁的线程入队操作
* @param node 要入队的线程节点
* @return 入队节点的前驱节点
*/
private Node enq(final Node node) {
// 自旋等待节点入队, 通过cas保证并发情况下node安全正确入队
for (;;) {
Node t = tail;
// head为空时构造dummy node初始化head和tail
if (t == null) {
if (compareAndSetHead(new Node()))
tail = head;
} else {
node.prev = t;
// 如果cas设置tail失败了
// 下个循环取到了最新的其他线程抢先设置的tail
// 继续尝试设置.
if (compareAndSetTail(t, node)) {
t.next = node;
return t;
}
}
}
}
/**
* 原子性的设置tail尾节点为新入队的节点
*/
private final boolean compareAndSetTail(Node expect, Node update) {
// 可以看到此处又是调用了Unsafe类下的原子操作方法
// 如果目标字段(tail尾节点字段)当前值是预期值
// 即没有被其他线程抢先修改成功, 那么就设置成功
// 返回true
return unsafe.compareAndSwapObject(this, tailOffset, expect, update);
}

企业开发中的乐观锁应用

除了JDK中Uusafe类提供的各种原子性操作外,我们实际开发中可以用CAS思想保证并发情况下安全的操作数据库。假设有user表结构以及数据如下, version字段是实现乐观锁的关键

id user coupon_num version
1 朱小明 0 0

假设我们有一个用户领取优惠券的按钮,怎么防止用户快速点击按钮造成重复领取优惠券的情况呢。我们要安全的更改id为1的用户的coupon_num优惠券数量,将version字段作为CAS比较的版本号,即可避免重复增加优惠券数量,比较和替换这个逻辑通过WHERE条件来实现. 涉及sql如下:

UPDATE user 
SET coupon_num = coupon_num + 1, version = version + 1
WHERE version = 0

可以看到,我们查询出id为1的数据, 版本号为0,修改数据的同时把当前版本号当做条件即可实现安全修改,如果修改失败,证明已经被其他线程修改过,然后看具体业务决定是否需要自旋尝试再次修改。这里要注意考虑竞争激烈的情况下多个线程自旋导致过度的性能消耗,根据并发量选择适合自己业务的方式

相关文章

java速学教程(入门到精通)
java速学教程(入门到精通)

java怎么学习?java怎么入门?java在哪学?java怎么学才快?不用担心,这里为大家提供了java速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

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

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
数据分析工具有哪些
数据分析工具有哪些

数据分析工具有Excel、SQL、Python、R、Tableau、Power BI、SAS、SPSS和MATLAB等。详细介绍:1、Excel,具有强大的计算和数据处理功能;2、SQL,可以进行数据查询、过滤、排序、聚合等操作;3、Python,拥有丰富的数据分析库;4、R,拥有丰富的统计分析库和图形库;5、Tableau,提供了直观易用的用户界面等等。

728

2023.10.12

SQL中distinct的用法
SQL中distinct的用法

SQL中distinct的语法是“SELECT DISTINCT column1, column2,...,FROM table_name;”。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

328

2023.10.27

SQL中months_between使用方法
SQL中months_between使用方法

在SQL中,MONTHS_BETWEEN 是一个常见的函数,用于计算两个日期之间的月份差。想了解更多SQL的相关内容,可以阅读本专题下面的文章。

350

2024.02.23

SQL出现5120错误解决方法
SQL出现5120错误解决方法

SQL Server错误5120是由于没有足够的权限来访问或操作指定的数据库或文件引起的。想了解更多sql错误的相关内容,可以阅读本专题下面的文章。

1263

2024.03.06

sql procedure语法错误解决方法
sql procedure语法错误解决方法

sql procedure语法错误解决办法:1、仔细检查错误消息;2、检查语法规则;3、检查括号和引号;4、检查变量和参数;5、检查关键字和函数;6、逐步调试;7、参考文档和示例。想了解更多语法错误的相关内容,可以阅读本专题下面的文章。

360

2024.03.06

oracle数据库运行sql方法
oracle数据库运行sql方法

运行sql步骤包括:打开sql plus工具并连接到数据库。在提示符下输入sql语句。按enter键运行该语句。查看结果,错误消息或退出sql plus。想了解更多oracle数据库的相关内容,可以阅读本专题下面的文章。

841

2024.04.07

sql中where的含义
sql中where的含义

sql中where子句用于从表中过滤数据,它基于指定条件选择特定的行。想了解更多where的相关内容,可以阅读本专题下面的文章。

581

2024.04.29

sql中删除表的语句是什么
sql中删除表的语句是什么

sql中用于删除表的语句是drop table。语法为drop table table_name;该语句将永久删除指定表的表和数据。想了解更多sql的相关内容,可以阅读本专题下面的文章。

423

2024.04.29

java入门学习合集
java入门学习合集

本专题整合了java入门学习指南、初学者项目实战、入门到精通等等内容,阅读专题下面的文章了解更多详细学习方法。

1

2026.01.29

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Kotlin 教程
Kotlin 教程

共23课时 | 3万人学习

C# 教程
C# 教程

共94课时 | 7.9万人学习

Java 教程
Java 教程

共578课时 | 52.8万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号