Làm cách nào để cập nhật Atomic dựa trên điều kiện?

Question

Cách cập nhật AtomicInteger nếu giá trị hiện tại của nó nhỏ hơn giá trị đã cho? Ý tưởng là:

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

Nếu bạn đang sử dụng Java 8, bạn có thể sử dụng một trong các phương pháp cập nhật mới trong AtomicInteger, bạn có thể chuyển biểu thức lambda. Ví dụ:

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

Nếu bạn không có Java 8, bạn có thể sử dụng một CAS-loop như thế này:

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