大于比较和交换

Question

正如标题所示，我正在寻找一种比较和交换的实现，但具有大于比较：

if(newValue > oldValue) {
    oldValue = newValue;
}

其中oldValue 是某个全局共享状态，newValue 是每个线程私有的，无需这样做：

synchronized(locker) {
    if(newValue > oldValue) {
        oldValue = newValue;
    }       
}

因为我想要一个非阻塞的解决方案。通过研究其他非阻塞操作的源代码，我想出了这个（假设值是整数）：

AtomicInteger oldValue; // shared global variable

...

public boolean GreaterThanCAS(int newValue) {

    while(true) {
        int local = oldValue;
        if(local == oldValue) {
            if(newValue > local) {
                 if(oldValue.compareAndSet(local, newValue) {
                     return true;  // swap successful
                 } // else keep looping
            } else {
                 return false; // swap failed
            }
        } // else keep looping
    }
}

当// else keep looping发生时，意味着另一个线程同时更改了oldValue，所以我需要循环再试一次。

这个实现是否正确（线程安全）？

Answer 1

从 Java 8 开始，这可以通过使用 updateAndGet 来简化：

public boolean greaterThanCAS(int newValue) {
    return oldValue.updateAndGet(x -> x < newValue ? newValue : x) == newValue;
}

请注意，如果旧值和新值相等，这也会返回 true。 如果这不是我们想要的行为，请尝试@Adam's answer。

Answer 2

我认为您的实现没有问题，只要没有线程会降低 AtomicInteger 的值。如果他们这样做了，您的代码将对竞争条件开放。

注意，代码可以简化如下：

public boolean GreaterThanCAS(int newValue) {
    while(true) {
        int local = oldValue.get();
        if(newValue <= local) {
             return false; // swap failed
        }
        if(oldValue.compareAndSet(local, newValue)) {
             return true;  // swap successful
        }
        // keep trying
    }
}

Answer 3

我会重写它看起来更像：

while(true) {
    int local = oldValue.get();
    if(newValue > local){
       if(oldValue.compareAndSwap(local, newValue) {
              return true;  // swap successful
        } // else keep looping 
    }else 
        return false;
 }

大于检查之前的等价检查是多余的。

否则它应该可以正常工作。

Answer 4

@Vadzim，我会评论你的帖子，但 stackoverflow 说我没有足够的积分来发布 cmets。您的答案几乎是正确的，但是您的函数将始终返回 false，因为 getAndUpdate 始终返回以前的值，或者在您的情况下返回“x”。我认为您需要做的就是将最后一个 '==' 替换为 '

 // return true if the assignment was made, false otherwise
 public boolean greaterThanCAS(int newValue) {
    return oldValue.getAndUpdate(x -> x < newValue ? newValue : x) < newValue;
 }