关键词：
文章目录
LongAdder
add方法
public void add(long x)
Cell[] as; long b, v; int m; Cell a;
if ((as = cells) != null || !casBase(b = base, b + x))
boolean uncontended = true;
if (as == null || (m = as.length - 1) < 0 ||
(a = as[getProbe() & m]) == null ||
!(uncontended = a.cas(v = a.value, v + x)))
longAccumulate(x, null, uncontended);
casBase
/**
* CASes the base field.
*/
final boolean casBase(long cmp, long val)
return UNSAFE.compareAndSwapLong(this, BASE, cmp, val);
- 1、如果Celsl未初始化，则会调用casBase方法即使用cas对base进行修改，如果修改成功，则返回，如果没有修改成功(存在竞争)，则会进if判断里面.
- 2、如果存在竞争，修改不成功，LongAdder会尝试定位到其中的一个Cell，通过更新这个Cell的值来维护整体的value。
longAccumulate方法
final void longAccumulate(long x, LongBinaryOperator fn,
boolean wasUncontended)
int h;
if ((h = getProbe()) == 0)
ThreadLocalRandom.current(); // force initialization
h = getProbe();
wasUncontended = true;
boolean collide = false; // True if last slot nonempty
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 Cell
Cell r = new Cell(x); // Optimistically create
if (cellsBusy == 0 && casCellsBusy())
boolean created = false;
try // Recheck under lock
Cell[] 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 fail
wasUncontended = true; // Continue after rehash
else 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
else if (!collide)
collide = true;
else if (cellsBusy == 0 && casCellsBusy())
try
if (cells == as) // Expand table unless stale
Cell[] 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 table
if (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
longAccumulate方法详解后面补充
总结
简单的讲:
- add 过程:
首先对 base 进行修改
修改失败,对 cells 进行初始化操作
初始化完成, 判断当前线程所在 cell 是否为 null
如果 为 null,则创建 ,不为 null,则进行修改 cell 的 value
修改失败的话,准备对 cells 数组进行扩容,不是立马扩容的. - 扩容的条件:(三个条件同时满足)
当前线程的 cell 第一次修改失败
“rehash” 后,换一个新的 cell 后还是失败
且能够获取锁,对当前 cells 进行操作, 才进行扩容
longadder类学习笔记(代码片段)
优秀原文LongAdder|LongAccumulator简介源码阅读:全方位讲解LongAdder说到LongAdder，不得不提的就是AtomicLong。AtomicLong是JDK1.5开始出现的，里面主要使用了一个long类型的value作为成员变量。它的原理是依靠底层CAS方式来保障原子性的更新... 查看详情
死磕java并发包之longadder源码分析(代码片段)
问题（1）java8中为什么要新增LongAdder？（2）LongAdder的实现方式？（3）LongAdder与AtomicLong的对比？简介LongAdder是java8中新增的原子类，在多线程环境中，它比AtomicLong性能要高出不少，特别是写多的场景。它是怎么实现的呢？让我们... 查看详情
死磕java并发包之longadder源码分析(代码片段)
问题（1）java8中为什么要新增LongAdder？（2）LongAdder的实现方式？（3）LongAdder与AtomicLong的对比？简介LongAdder是java8中新增的原子类，在多线程环境中，它比AtomicLong性能要高出不少，特别是写多的场景。它是怎么实现的呢？让我们... 查看详情
juca：longadder(代码片段)
LongAdder是什么？很多人根本连API文档都没有好好读，就喜欢吵着“JUC大法好，底层实现妙妙妙”，然后就钻入低层实现的分析了，浮躁是搞技术的大忌。LongAdder的类文档说明如下：一个或多个变量一起来维持一个初始为0的long类... 查看详情
longadder原理分析(代码片段)
LongAdder由来LongAdder类是JDK1.8新增的一个原子性操作类。AtomicLong通过CAS算法提供了非阻塞的原子性操作，相比受用阻塞算法的同步器来说性能已经很好了，但是JDK开发组并不满足于此，因为非常搞并发的请求下AtomicLong... 查看详情
jdk源码分析--longadder(代码片段)
...、简介当多个线程更新用于诸如收集统计信息（因为LongAdder多线程时候会有误差）而不是用于细粒度同步控制之类的公共和时，此类通常比AtomicLong更可取。在低更新争用下，这两个类具有相似的特征。但是在竞争... 查看详情
longadder和atomiclong性能对比(代码片段)
jdk1.8中新原子操作封装类LongAdder和jdk1.5的AtomicLong和synchronized的性能对比，直接上代码：packagecom.itbac.cas;importjava.util.concurrent.atomic.AtomicLong;importjava.util.concurrent.atomic.LongAdder;//测试用例：同时运行2秒，检查谁的次数最多publicclassLong... 查看详情
java中的并发计数器longadder(代码片段)
并发计数器LongAdder基本概念Striped64Striped64重要成员变量cellscellsBusybase内部类CellCPU缓存架构缓存行cacheline伪共享Striped64重要方法longAccumulateLongAdderLongAdder重要方法add总结hash的值生成threadLocalRandomProbe初始化threadLocalRandomProbe重新 查看详情
longadder和atomiclong哪个性能更好，为什么？(代码片段)
点击关注公众号，实用技术文章及时了解来源：blog.csdn.net/limenghua9112/article/details/107950744概述AtomicLong是作者DougLea在jdk1.5版本发布于java.util.concurrent.atomic并发包下的类。而LongAdder是道格·利（DougLea的中文名）在j 查看详情
java中的并发计数器longadder(代码片段)
并发计数器LongAdder基本概念Striped64Striped64重要成员变量cellscellsBusybase内部类CellCPU缓存架构缓存行cacheline伪共享Striped64重要方法longAccumulateLongAdderLongAdder重要方法add总结hash的值生成threadLocalRandomProbe初始化threadLocalRandomProbe重新生成... 查看详情
jdk源码分析--longadder(代码片段)
...、简介当多个线程更新用于诸如收集统计信息（因为LongAdder多线程时候会有误差）而不是用于细粒度同步控制之类的公共和时，此类通常比AtomicLong更可取。在低更新争用下，这两个类具有相似的特征。但是在竞争... 查看详情
面试官：为什么longadder性能比long还快(代码片段)
你知道的越多，不知道的就越多，业余的像一棵小草！你来，我们一起精进！你不来，我和你的竞争对手一起精进！编辑：业余草zhuanlan.zhihu.com/p/45489739推荐：https://www.xttblog.com/?p=5261通过最... 查看详情
面试必备：javajucatomiclongadder详解
...面试必备：JavaJUCAtomicLong实现解析LongAdder是JDK1.8新增的原子类，基于Striped64实现。从官方文档看，LongAdder在高并发的场景下会比AtomicLong具有更好的性能，代价是 查看详情
juc并发编程--原子数组&原子更新器(字段更新器)&原子累加器(longadder)(代码片段)
1.原子数组有的时候我们不需要修改引用本身，我们要修改的是里面的内容，这时就需要用到原子数组。原子数组:AtomicIntegerArrayAtomicLongArrayAtomicReferenceArray示例代码:packagetian;importjava.util.ArrayList;importjava.util.Arrays;importjava.ut... 查看详情
atomicxxx用的好好的，阿里为什么推荐使用longadder？面试必问。。。(代码片段)
面试连环炮先来一连炮简单的面试，看你能顶住几轮？栈长：1、多线程情况下，进行数字累加（count++）要注意什么？张三：要注意给累加方法加同步锁，不然会出现变量可见性问题，变量值被其他线程覆盖出现不一致的情况栈... 查看详情
javareview-并发编程_原子操作类longadder&longaccumulator剖析(代码片段)
...)add(longx)longAccumulate(longx,LongBinaryOperatorfn,booleanwasUncontended)LongAdder小结LongAccumulator概述LongAdder#addvsLongAccumulator#accumulate小Demo原子类总结概述JavaReview-并发编程_原子操作类原理剖析中提到了AtomicLong通过CAS提供了非阻塞的原子性操作&#... 查看详情
javareview-并发编程_jdk8新增的原子操作类longadder&longaccumulator(代码片段)
...)add(longx)longAccumulate(longx,LongBinaryOperatorfn,booleanwasUncontended)LongAdder小结LongAccumulator概述LongAdder#addvsLongAccumulator#accumulate小Demo原子类总结概述JavaReview-并发编程_原子操作类原理剖析中提到了AtomicLong通过CAS提供了非阻塞的原子性操作&#... 查看详情
javalongadder原子累加器源码深度解析(代码片段)
基于JDK1.8详细介绍了JUC下面的LongAdder原子类源码和原理，LongAdder是Java8对于原子类的增强。文章目录1原子类的加强1.1LongAdder1.1.1LongAdder的概述1.1.2LongAdder的原理1.1.2.1内部结构1.1.2.2add增加给定值1.1.2.2.1longAccumulate统一处理1.1.2.3i... 查看详情