Come aggiornare un atomico in base a una condizione?

Question

Come aggiornare un AtomicInteger se il suo valore attuale è inferiore al valore dato? L'idea è:

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

Se si utilizza Java 8 è possibile utilizzare uno dei nuovi metodi di aggiornamento in AtomicInteger, che è possibile passare un'espressione lambda. Per esempio:

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

Se non si dispone di Java 8, è possibile utilizzare un CAS-loop in questo modo:

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