LongAccumulator是Java 8提供的支持自定义二元累积操作的高并发原子类,构造需传入满足单位元性质的累加函数和初始值,适用于求最大值、最小值、异或、乘积等场景。

LongAccumulator 是 Java 8 引入的原子类,适用于需要自定义累积逻辑(不只是简单加法)的高并发场景。它比 AtomicLong 更灵活,比 LongAdder 更通用——后者只支持加法,而前者支持任意二元操作(如取最大值、最小值、异或、乘积等)。
理解 LongAccumulator 的核心参数
构造时需传入两个关键参数:
-
累加函数(BinaryOperator<Long>):定义两个 long 值如何合并,例如
(x, y) -> x + y或Math::max; -
初始值(identity):当没有调用过
accumulate()时,get()返回的值,必须满足:对任意 x,有fn.apply(identity, x) == x(即满足单位元性质)。
例如,加法的单位元是 0,最大值的单位元是 Long.MIN_VALUE,最小值是 Long.MAX_VALUE,异或是 0。
常用累积模式示例
不必只做加法。以下是一些典型用法:
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
立即学习“Java免费学习笔记(深入)”;
-
求最大值:
new LongAccumulator(Math::max, Long.MIN_VALUE); -
求最小值:
new LongAccumulator(Math::min, Long.MAX_VALUE); -
按位异或:
new LongAccumulator((x, y) -> x ^ y, 0L); -
乘积(注意溢出):
new LongAccumulator((x, y) -> x * y, 1L)。
正确使用 accumulate() 和 get()
accumulate(x) 将 x 按指定函数与当前值合并,线程安全;get() 获取当前累积结果。注意:
- 不能直接修改返回值(如
acc.get()++),这不具原子性; - 若需条件更新,可用
accumulateThenGet(x)或getThenAccumulate(x); -
reset()会重置为初始值,适合周期性统计场景(如每秒汇总)。
和 LongAdder 的关系与选择
LongAdder 本质是 LongAccumulator 的特例:new LongAccumulator((x, y) -> x + y, 0L)。如果只需加法且追求极致性能,LongAdder 略轻量;但一旦需要非加法逻辑,LongAccumulator 是唯一选择。两者都采用分段累加+最终合并策略,避免热点变量竞争。

















