Как обновить Atomic на основе условия?

Question

Как обновить AtomicInteger, если его текущее значение меньше заданного значения? Идея такова:

AtomicInteger ai = new AtomicInteger(0); 
... 
ai.update(threadInt); // this call happens concurrently 
... 
// inside AtomicInteger atomic operation 
synchronized { 
    if (ai.currentvalue < threadInt) 
     ai.currentvalue = threadInt; 
} 

Answer 1

Если вы используете Java-вы можете использовать один из новых методов обновления в AtomicInteger, которые можно передать лямбда-выражение. Например:

AtomicInteger ai = new AtomicInteger(0); 

int threadInt = ... 

// Update ai atomically, but only if the current value is less than threadInt 
ai.updateAndGet(value -> value < threadInt ? threadInt : value); 

Answer 2

Если у вас нет Java 8, вы можете использовать CAS-цикл вроде этого:

while (true) { 
    int currentValue = ai.get(); 
    if (newValue > currentValue) { 
     if (ai.compareAndSet(currentValue, newValue)) { 
      break; 
     } 
    } 
}