正如标题所示,我正在寻找一种比较和交换实现,但是比较大：
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
}
}
