java – 大于比较和交换

正如标题所示,我正在寻找一种比较和交换实现,但是比较大：

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.compareAndSwap(local,newValue) {
                     return true;  // swap successful
                 } // else keep looping
            } else {
                 return false; // swap Failed
            }
        } // else keep looping
    }
}

当// else保持循环发生时,这意味着另一个线程在此期间更改了oldValue,因此我需要循环并重试.

这个实现是否正确(线程安全)？

解决方法

如果没有线程减少AtomicInteger的值,我认为您的实现没有问题.如果他们这样做,您的代码是可以竞争的条件.

请注意,代码可以简化如下：

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