Wie wird ein Atomic basierend auf einer Bedingung aktualisiert?

Question

Wie wird ein AtomicInteger aktualisiert, wenn der aktuelle Wert kleiner als der angegebene Wert ist? Die Idee ist:

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

Wenn Sie mit Java 8 Sie eines der neuen Update-Methoden in AtomicInteger verwenden können, die Ihnen einen Lambda-Ausdruck passieren kann. Zum Beispiel:

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

Wenn Sie nicht Java 8 haben, können Sie eine CAS-Schleife wie folgt verwenden:

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