multithreading - LongAdder Striped64 wasUncontended 实现细节

这不是关于 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 到已经存在的值，而是重新散列探测。

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

最佳答案

不是它会失败，而是它已经失败了。对该方法的调用由 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);
    }
}

第一组条件与长单元格的存在有关。如果必要的单元格不存在，那么它将尝试通过原子地添加必要的单元格然后添加来累积无竞争的(因为没有尝试添加)。

如果单元格确实存在，请尝试添加 ( v + x )。如果添加失败，则存在某种形式的争用，在这种情况下，尝试乐观地/原子地进行累积(旋转直到成功)

那么为什么它有

wasUncontended = true;      // Continue after rehash

我最好的猜测是，在激烈的竞争中，它会尝试给正在运行的线程时间 catch ，并会强制重试现有的单元格。

关于multithreading - LongAdder Striped64 wasUncontended 实现细节，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/41121885/