浅谈比LongAdder功能更强大的LongAccumulator

简介: 浅谈比LongAdder功能更强大的LongAccumulator

一、前言


上一期分析了LongAdder的原理,这期我们来学习下比LongAdder功能更强大的LongAccumulator。要是上期LongAdder不记得的同学就再看看这篇:高并发下解决AtomicLong性能瓶颈的方案——LongAdder 来回顾一下~LongAdder是本期要学习的LongAccumulator的一个特例,下面我们一起来探究下LongAccumulator。


二、浅谈LongAccumulator


1、LongAccumulator的结构


如图,LongAccumulator类同样地也是继承自Striped64类:


20201116200701448.png


这意味着LongAccumulator类也是一个高并发累加的类。


2、构造方法


LongAccumulator的构造方法如下:

  public LongAccumulator(LongBinaryOperator accumulatorFunction,
                           long identity) {
        this.function = accumulatorFunction;
        base = this.identity = identity;
    }


LongBinaryOperator 是一个双目运算器接口,并根据输入的两个参数返回一个计算值;identity是LongAccumulator累加器的初始值。


这是LongBinaryOperator接口的结构:

@FunctionalInterface
public interface LongBinaryOperator {
    long applyAsLong(long left, long right);
}

可以看到LongBinaryOperator接口是更加两个long类型的参数返回一个值。


3、初始化LongAccumulator


看完LongAccumulator的构造方法,来看看它怎么用。

    LongAccumulator longAccumulator = new LongAccumulator(new LongBinaryOperator() {
            @Override
            public long applyAsLong(long left, long right) {
                return left + right;
            }
        }, 2);

由Java8的新特性,也可以写成以下形式:


LongAccumulator longAccumulator = new LongAccumulator((left, right) -> left + right, 2);


上述代码中,我们使用LongAccumulator创建了一个初值为2的累加器。先比起LongAdder,LongAccumulator 可以为累加器提供非0的初始值,而LongAdder只能提供默认的0值。另外,LongAccumulator还可以提供累乘等运算(只需要我们自己定义双目运算器),而LongAdder内置累加规则。例如,我们可以使用下面的代码来定义一个累乘器:

 LongAccumulator longAccumulator = new LongAccumulator((left, right) -> left * right, 2);

4、LongAccumulator与LongAdder的不同之处


LongAccumulator的accumulate方法:


  public void accumulate(long x) {
        Cell[] as; long b, v, r; int m; Cell a;
        if ((as = cells) != null ||
            (r = function.applyAsLong(b = base, x)) != b && !casBase(b, r)) {
            boolean uncontended = true;
            if (as == null || (m = as.length - 1) < 0 ||
                (a = as[getProbe() & m]) == null ||
                !(uncontended =
                  (r = function.applyAsLong(v = a.value, x)) == v ||
                  a.cas(v, r)))
                longAccumulate(x, function, uncontended);
        }
    }

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);
        }
    }

仔细观察可以发现两者区别:


(1)调用casBase方法传入的参数不同。LongAccumulator的casBase传入的第二个参数是:r = function.applyAsLong(b = base, x),根据LongBinaryOperator的运算规则来执行CAS;而LongAdder的casBase传入的第二个参数是:b+x ,也就是一个简单的累加规则来执行CAS。

(2)调用longAccumulate方法传入的参数不同。LongAccumulator传递的是function,LongAdder传递的是null。


 else if (a.cas(v = a.value, ((fn == null) ? v + x :fn.applyAsLong(v, x))))
      break;


这行代码告诉我们当fn为null是执行累加运算,否则执行LongBinaryOperator的运算规则。


三、总结


本期主要讲了LongAccumulator比LongAdder更强大的地方:


  • 累加的初始值可以自定义
  • 运算规则可以自定义


然后简单看了下LongAccumulator的构造,并分析了LongAccumulator的accumulate方法与LongAdder的add方法的不同。LongAccumulator更具体的实现原理与LongAdder并没有什么差异,所以就不过多赘述了,有兴趣的小伙伴可以自行阅读下。本期就到这里吧。

相关文章
|
Kubernetes Dubbo Nacos
nacos常见问题之Nacos国内下载Nacos 太慢如何解决
Nacos是阿里云开源的服务发现和配置管理平台,用于构建动态微服务应用架构;本汇总针对Nacos在实际应用中用户常遇到的问题进行了归纳和解答,旨在帮助开发者和运维人员高效解决使用Nacos时的各类疑难杂症。
2428 3
|
开发工具 iOS开发 MacOS
解决VScode文件无法编辑(删除键 换行键失去作用)
解决VScode文件无法编辑(删除键 换行键失去作用)
3282 0
|
消息中间件 存储 编解码
『Logstash』Logstash配置文件详解
📣读完这篇文章里你能收获到 - Logstash配置文件详解
1955 0
『Logstash』Logstash配置文件详解
|
7月前
|
安全
【📕分布式锁通关指南 07】源码剖析redisson利用看门狗机制异步维持客户端锁
Redisson 的看门狗机制是解决分布式锁续期问题的核心功能。当通过 `lock()` 方法加锁且未指定租约时间时,默认启用 30 秒的看门狗超时时间。其原理是在获取锁后创建一个定时任务,每隔 1/3 超时时间(默认 10 秒)通过 Lua 脚本检查锁状态并延长过期时间。续期操作异步执行,确保业务线程不被阻塞,同时仅当前持有锁的线程可成功续期。锁释放时自动清理看门狗任务,避免资源浪费。学习源码后需注意:避免使用带超时参数的加锁方法、控制业务执行时间、及时释放锁以优化性能。相比手动循环续期,Redisson 的定时任务方式更高效且安全。
399 24
【📕分布式锁通关指南 07】源码剖析redisson利用看门狗机制异步维持客户端锁
|
6月前
|
存储 安全 NoSQL
【📕分布式锁通关指南 09】源码剖析redisson之公平锁的实现
本文深入解析了 Redisson 中公平锁的实现原理。公平锁通过确保线程按请求顺序获取锁,避免“插队”现象。在 Redisson 中,`RedissonFairLock` 类的核心逻辑包含加锁与解锁两部分:加锁时,线程先尝试直接获取锁,失败则将自身信息加入 ZSet 等待队列,只有队首线程才能获取锁;解锁时,验证持有者身份并减少重入计数,最终删除锁或通知等待线程。其“公平性”源于 Lua 脚本的原子性操作:线程按时间戳排队、仅队首可尝试加锁、实时发布锁释放通知。这些设计确保了分布式环境下的线程安全与有序执行。
186 0
【📕分布式锁通关指南 09】源码剖析redisson之公平锁的实现
|
存储 安全 文件存储
UGREEN NAS
【6月更文挑战第30天】UGREEN NAS
460 59
|
12月前
|
监控 网络安全 调度
Quartz.Net整合NetCore3.1,部署到IIS服务器上后台定时Job不被调度的解决方案
解决Quartz.NET在.NET Core 3.1应用中部署到IIS服务器上不被调度的问题,通常需要综合考虑应用配置、IIS设置、日志分析等多个方面。采用上述策略,结合细致的测试和监控,可以有效地提高定时任务的稳定性和可靠性。在实施任何更改后,务必进行充分的测试,以验证问题是否得到解决,并监控生产环境的表现,确保长期稳定性。
649 1
|
安全 Java 开发者
深入解析ReentrantLock重入锁:Java多线程中的利器
深入解析ReentrantLock重入锁:Java多线程中的利器
2618 4
|
12月前
【编程基础知识】正数负数的二进制位运算(左移 右移 无符号右移)
正数和负数需转换成二进制后进行移位运算。左移低位补0,不影响符号位;右移符号位跟随移动,最高位还原为原符号位;无符号右移高位补0,适用于负数处理。
750 0
|
存储 Java 编译器
每日一博 - Protobuf vs. Protostuff:性能、易用性和适用场景分析
每日一博 - Protobuf vs. Protostuff:性能、易用性和适用场景分析
474 0