3

这不是关于 LongAdder 如何工作的问题，而是关于我无法弄清楚的有趣的实现细节。

这是来自 Striped64 的代码（我已经剪掉了一些部分并将相关部分留给问题）：

    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) {
                //logic to insert the Cell in the array
            }
            // CAS already known to fail
            else if (!wasUncontended)   {
                wasUncontended = true;      // Continue after rehash
            }
            else if (a.cas(v = a.value, ((fn == null) ? v + x : fn.applyAsLong(v, x)))){
                break;
            }

代码中的很多东西对我来说都很清楚，除了：

        // CAS already known to fail
        else if (!wasUncontended)   {
            wasUncontended = true;      // Continue after rehash
        }

以下 CAS 将失败的确定性在哪里？至少这对我来说真的很令人困惑，因为这种检查只对一种情况有意义：当某个线程第 n 次（n > 1）进入longAccumulate方法并且忙自旋处于它的第一个周期时。

就像这段代码在说：如果您（某个线程）以前曾来过这里并且您对特定的 Cell 插槽有一些争用，请不要尝试将您的值 CAS 到已经存在的值，而是重新散列探测。

老实说，我希望我会对某人有意义。

4

1 回答 1

4

不是它会失败，而是它失败了。对该方法的调用由该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. 第一组条件与长单元的存在有关。如果必要的单元格不存在，那么它将尝试通过原子地添加必要的单元格然后添加来累积无竞争（因为没有尝试添加）。
  2. 如果单元格确实存在，请尝试添加 ( v + x)。如果添加失败，则存在某种形式的争用，在这种情况下，尝试乐观/原子地进行累积（旋转直到成功）

那为什么它有

wasUncontended = true;      // Continue after rehash

我最好的猜测是，在竞争激烈的情况下，它会尝试让正在运行的线程有时间赶上并强制重试现有的单元格。

于 2016-12-13T13:42:43.127 回答