AtomicLong和LongAdder的区别
转载自 https://blog.csdn.net/yao123long/article/details/63683991
前言
最近在看到不少框架里面使用到了LongAdder这个类,而并非AtomicLong,很是困惑,于是专门看了LongAdder的源码,总结一下这两个的区别。
AtomicLong原理
就像我们所知道的那样,AtomicLong的原理是依靠底层的cas来保障原子性的更新数据,在要添加或者减少的时候,会使用死循环不断地cas到特定的值,从而达到更新数据的目的。那么LongAdder又是使用到了什么原理?难道有比cas更加快速的方式?
LongAdder原理
首先我们来看一下LongAdder有哪些方法?
可以看到和AtomicLong基本类似,同样有增加、减少等操作,那么如何实现原子的增加呢?
我们可以看到一个Cell的类,那这个类是用来干什么的呢?
我们可以看到Cell类的内部是一个volatile的变量,然后更改这个变量唯一的方式通过cas。我们可以猜测到LongAdder的高明之处可能在于将之前单个节点的并发分散到各个节点的,这样从而提高在高并发时候的效率。
下面我们来验证我们的观点,我们接着看上图的add方法,如果cell数组不为空,那么就尝试更新base元素,如果更新成功,那么就直接返回。base元素在这里起到了一个什么作用呢?可以保障的是在低并发的时候和AtomicLong一样的直接对基础元素进行更新。
而如果cell为空或者更新base失败,我们看接下来的那个if判断,即如果as不为空并且成功更新对应节点的数据,则返回,否则就会进入longAccumulate()方法。
图有点大,无法截图,直接贴源码
for (;;) {Cell[] as; Cell a; int n; long v;if ((as = cells) != null && (n = as.length) > 0) {if ((a = as[(n - 1) & h]) == null) { //如果对应位置没有数据,那么直接插入元素if (cellsBusy == 0) { // Try to attach new CellCell r = new Cell(x); // Optimistically createif (cellsBusy == 0 && casCellsBusy()) {boolean created = false;try { // Recheck under lockCell[] rs; int m, j;if ((rs = cells) != null &&(m = rs.length) > 0 &&rs[j = (m - 1) & h] == null) {rs[j] = r;created = true;}} finally {cellsBusy = 0;}if (created)break;continue; // Slot is now non-empty}}collide = false;}else if (!wasUncontended) //标示冲突标志位 ,进行重试 CAS already known to failwasUncontended = true; // Continue after rehashelse if (a.cas(v = a.value, ((fn == null) ? v + x :fn.applyAsLong(v, x))))break;else if (n >= NCPU || cells != as)collide = false; // At max size or stale,如果已经cell数组的大小已经超过了CPU核数,那么再扩容没意义了,直接重试,或者有别的线程扩容导致变更了数组,设置标示位,进行重试,,避免一失败就扩容else if (!collide)collide = true;else if (cellsBusy == 0 && casCellsBusy()) {//开始扩容try {if (cells == as) { // Expand table unless staleCell[] rs = new Cell[n << 1];for (int i = 0; i < n; ++i)rs[i] = as[i];cells = rs;}} finally {cellsBusy = 0;}collide = false;continue; // Retry with expanded table}h = advanceProbe(h); //扩容完成以后,重新初始化要更新的索引值,尽量保障可以更新成功}else if (cellsBusy == 0 && cells == as && //初始化casCellsBusy()) {boolean init = false;try { // Initialize tableif (cells == as) {Cell[] rs = new Cell[2];rs[h & 1] = new Cell(x);cells = rs;init = true;}} finally {cellsBusy = 0;}if (init)break;}else if (casBase(v = base, ((fn == null) ? v + x :fn.applyAsLong(v, x))))break; // Fall back on using base}
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
- 52
- 53
- 54
- 55
- 56
- 57
- 58
- 59
- 60
- 61
- 62
- 63
- 64
- 65
- 66
- 67
- 68
- 69
- 70
上面的代码主要有三个分支:
1. 如果数组不为空
2. 数据为空,则初始化
3. 前面都更新失败了,尝试更新base数据
cellBusy是一个标示元素,只有当修改cell数组大小或者插入元素的时候才会修改。分支二、分支三都很简单,我们来重点分析一下分支一。
当要更新的位置没有元素的时候,首先cas标志位,防止扩容以及插入元素,然后插入数据。如果成功直接返回,否则标示发生了冲突,然后重试。如果对应的位置有元素则更新,如果更新失败,进行判断是否数组的大小已经超过了cpu的核数,如果大于的话,则意味着扩容没有意义。直接重试。否则进行扩容,扩容完成后,重新设置要更新的位置,尽可能保证下一次更新成功。
我们来看一下如何统计计数。
当计数的时候,将base和各个cell元素里面的值进行叠加,从而得到计算总数的目的。这里的问题是在计数的同时如果修改cell元素,有可能导致计数的结果不准确。
总结:
LongAdder在AtomicLong的基础上将单点的更新压力分散到各个节点,在低并发的时候通过对base的直接更新可以很好的保障和AtomicLong的性能基本保持一致,而在高并发的时候通过分散提高了性能。
缺点是LongAdder在统计的时候如果有并发更新,可能导致统计的数据有误差。
AtomicLong和LongAdder的区别相关推荐
- AtomicLong与LongAdder执行效率对比
AtomicLong与LongAdder执行效率对比: package com.mashibing.juc.c_018_00_AtomicXXX;import java.util.concurrent ...
- atomiclong 初始化_AtomicLong与LongAdder的区别
AtomicLong的原理 AtomicLong是通过依靠底层的CAS来保障原子性的更新数据,在要添加或者减少的时候,会使用死循环不断地cas到特定的值,从而达到更新数据的目的. LongAdder的 ...
- 性能远超AtomicLong,LongAdder原理完全解读
高并发场景下可以选择 AtomicLong 原子类进行计数等操作,除了 AtomicLong,在 jdk1.8 中还提供了 LongAdder.PS:AtomicLong 在 jdk1.5 版本提供. ...
- CAS和AtomicLong和LongAdder
1.Java中,锁占了并发的一席之地,但是锁带来的弊端就是线程会频繁的阻塞挂起,导致上下文的切换和重新调度,增加了系统开销.CAS 即 Compare and Swap(Change),是 JDK 提 ...
- 从AtomicLong 到 LongAdder
AtomicLong性能瓶颈分析 AtomicLong关键代码他用得是Unsafe的代码: public final long getAndAddLong(Object var1, long var2 ...
- LongAdder和AtomicLong哪个性能更好,为什么?
点击关注公众号,实用技术文章及时了解 来源:blog.csdn.net/limenghua9112/ article/details/107950744 概述 AtomicLong是作者Doug Le ...
- 【078期】java.util.* 并发包下 LongAdder 和 AtomicLong 哪个性能更好,为什么?
点击上方"Java精选",选择"设为星标" 别问别人为什么,多问自己凭什么! 下方留言必回,有问必答! 每天 08:00 更新文章,每天进步一点点... 概述 ...
- 性能优化之使用LongAdder替换AtomicLong
欢迎关注方志朋的博客,回复"666"获面试宝典 来源:https://juejin.cn/post/6921595303460241415 写在前面 本篇文章并不会直接进入主题讲为 ...
- [JDK8]性能优化之使用LongAdder替换AtomicLong
如果让你实现一个计数器,有点经验的同学可以很快的想到使用AtomicInteger或者AtomicLong进行简单的封装. 因为计数器操作涉及到内存的可见性和线程之间的竞争,而Atomic***的实现 ...
最新文章
- 2020年信号与系统课程批改工作处理程序
- Internet Explorer 9.0 正式版试用一点小总结
- 微软Tech Summit 2017,等你来打Call
- 如何写出优雅的跨平台的C/C++代码
- 解决Spring JdbcTemplate调用queryForObject()方法结果集为空时报异常
- mysql主从同步触发器_Mysql 主从复制触发器问题
- esx4克隆后的处理工作
- python实现完整的求解给定列表中所有的平衡点问题,是所有的平衡点
- JavaScript,5种调用函数的方法
- 可视化网络监控软件OpManager获选″IT运维产品之星”
- java.sql.Date.valueOf处理日期格式IllegalArgumentException异常
- 2016年米其林指南—澳门小食篇 -吃遍澳门,就这12家!
- 函数图像生成器 (吉林大学 孙立鑫)
- acg-faka--功能丰富的发卡二次元商城源码
- 由 tpp.c:63: __pthread_tpp_change_priority failed 引发的思考
- 1060显卡支持dx12吗_GTX1660和GTX1060哪个性价比高?GTX1060和GTX1660显卡区别对比
- 小型数控雕刻机制作Arduino_Arduino 3D打印机,兼具CNC雕刻机功能 (一)机械设计、组装...
- IT行业工作的就业方向
- 免费创建一个令人惊叹的网站的7个技巧
- Linux---如何打开文本文件