java 8：LongAdder 和 LongAccumulator 是否优于 AtomicLong？

Question

LongAdder 作为AtomicLong 的替代品

ExecutorService executor = Executors.newFixedThreadPool(2);    
IntStream.range(0, 1000)
    .forEach(i -> executor.submit(adder::increment));    
stop(executor);    
System.out.println(adder.sumThenReset());   // => 1000

LongAccumulator 是LongAdder 的更通用版本

LongBinaryOperator op = (x, y) -> 2 * x + y;
LongAccumulator accumulator = new LongAccumulator(op, 1L);

ExecutorService executor = Executors.newFixedThreadPool(2);
IntStream.range(0, 10)
    .forEach(i -> executor.submit(() -> accumulator.accumulate(i)));
stop(executor);

System.out.println(accumulator.getThenReset());     // => 2539

我有一些疑问。

1. LongAdder 总是优先于 AtomicLong 吗？
2. LongAccumulator 是否优于 LongAdder 和 AtomicLong？

Answer 1

Javadoc 中提到了这些类之间的区别，以及何时使用其中一个。来自LongAdder：

当多个线程更新用于收集统计信息等目的的公共总和时，此类通常优于AtomicLong，而不是用于细粒度的同步控制。在低更新争用下，这两个类具有相似的特征。但是在高竞争下，这个类的预期吞吐量明显更高，代价是更高的空间消耗。

来自LongAccumulator：

当多个线程更新用于收集统计信息等目的的公共值时，此类通常比AtomicLong 更可取，而不是用于细粒度的同步控制。在低更新争用下，这两个类具有相似的特征。但是在高竞争下，这个类的预期吞吐量明显更高，代价是更高的空间消耗。

[...]

LongAdder 类为维护计数和总和的常见特殊情况提供此类功能的类似物。调用new LongAdder() 等效于new LongAccumulator((x, y) -> x + y, 0L)。

因此，使用其中一个取决于您的应用程序打算做什么。它并不总是严格优选的，只有在预期高并发并且您需要保持公共状态时。

Answer 2

@Tunaki 巧妙地回答了这个问题，但仍然有一个问题影响了选择。

添加到单元需要每个线程一个单元。内部代码使用 Striped64 中的 getProbe() 返回：

return UNSAFE.getInt(Thread.currentThread(), PROBE);

Probe 是 threadLocalRandomSeed 中使用的系统字段。

我的理解是每个线程的探针都是唯一的。如果您有大量线程创建/销毁，则为每个新线程创建探针。

因此，Cell 的数量可能会过多。如果有人对此有更多详细信息，我想听听你的意见。