doubleaccumulator适合高并发、只写多读取少、允许最终一致的累加场景,如实时统计请求耗时总和、聚合监控指标;它支持自定义累积函数,非仅加法,但需注意幂等性、避免高频get、不解决浮点精度问题。

DoubleAccumulator 适合什么场景?
它不是用来替代 AtomicDouble(Java 根本没有这个类)的通用浮点原子变量,而是专为「高并发、只写多、读取少、允许最终一致」的累加场景设计的——比如实时统计请求耗时总和、聚合监控指标、计算采样均值的分子部分。
- 如果你需要频繁调用
add(x),且线程数常超过 10,DoubleAccumulator比AtomicLong转换再除 1e6 更快、比锁更轻量 - 如果你要保证每次
get()都立刻反映最新值(强一致性),别用它——它的get()是合并多个 Cell 的快照,可能略滞后 - 如果你要做非加法运算(比如取最大值、最小值、乘积),它支持,但必须显式传入函数,不能像
DoubleAdder那样只做加法
和 DoubleAdder 有什么关键区别?
DoubleAdder 是 DoubleAccumulator 的特例:它内部固定使用 (x, y) -> x + y 作为累积函数;而 DoubleAccumulator 允许你传任意 DoubleBinaryOperator,比如 Math::max、Math::min,甚至自定义的 (a, b) -> a * b * 0.99。
- 构造方式不同:
new DoubleAdder()无参;new DoubleAccumulator((a,b)->a+b, 0.0)必须传函数和初始值 - 性能上,纯累加场景二者底层都基于
Striped64,差异极小;但自定义逻辑多了函数调用开销,别滥用复杂 lambda - 初始化值语义不同:
DoubleAdder初始为 0.0;DoubleAccumulator的初始值是“中性元”,比如用Math::max就该传Double.NEGATIVE_INFINITY
常见误用与踩坑点
最典型的错误是把它当普通变量反复读写,或者在循环里高频调用 get() ——这会触发全量 Cell 合并,反而拖慢性能。
- 别在 hot loop 里写
if (acc.get() > threshold) { ... };改用accumulate(...)或定期采样 - 不要期望
accumulate(x)返回新值:它返回void,想拿当前结果得单独调get() - 传入的
DoubleBinaryOperator必须是无副作用、幂等的;若函数内修改外部状态或依赖时间/随机数,结果不可预测 - 它不解决浮点精度问题:
0.1 + 0.2 != 0.3依然成立,它只保证“加法操作本身”是线程安全的
一个真实可用的监控指标示例
假设你要统计每秒所有 HTTP 请求的耗时总和,用 DoubleAccumulator 比锁或 AtomicLong 更稳:
DoubleAccumulator totalLatency = new DoubleAccumulator(Double::sum, 0.0);
<p>// 在请求拦截器里
void onRequestEnd(double ms) {
totalLatency.accumulate(ms); // 线程安全,无锁,高吞吐
}</p><p>// 每秒一次,导出指标(不在高频路径)
double sum = totalLatency.get(); // 此时才合并,开销可控
totalLatency.reset(); // 清零,准备下一秒</p>注意 reset() 不是原子的——它先设 base 为 0,再逐个清空 Cell,期间若有线程正在 accumulate,可能漏掉少量值;对监控指标来说,这种微小误差可接受。










