Jaki jest pożytek z AtomicReferenceArray?

Question

Kiedy to jest dobry pomysł, aby użyć AtomicReferenceArray? Proszę wyjaśnić na przykładzie.

Answer 1

wygląda na to, że jest funkcjonalnie równoważne AtomicReference[], zajmując jednak nieco mniej pamięci.

Jest to przydatne, gdy potrzebujesz więcej niż milion odniesień atomowych - nie można wymyślić żadnego przypadku użycia.

Answer 2

Może to być przydatne, jeśli masz dużą liczbę obiektów aktualizowanych jednocześnie, na przykład w dużej grze wieloosobowej.

Aktualizacja odniesienia i byłoby zgodne z wzorcem

boolean success = false; 
while (!success) 
{ 
    E previous = atomicReferenceArray.get(i); 
    E next = ... // compute updated object 
    success = atomicReferenceArray.compareAndSet(i, previous, next); 
} 

W zależności od okoliczności może to być szybsze i/lub łatwiejsze w użyciu niż blokujący (synchronized).

Answer 3

Jeśli dysponujesz wspólną tablicą referencji do obiektów, użyjesz AtomicReferenceArray, aby zapewnić, że tablica nie może być aktualizowana jednocześnie przez różne wątki, tj. Tylko jeden element może być aktualizowany na raz.

Jednak w AtomicReference[] (tablica z AtomicReference) wiele wątków może nadal aktualizować różne elementy w sposób symulujący, ponieważ atomowość jest na elementach, a nie na tablicy jako całości.

Więcej informacji here.

Answer 4

Jednym z możliwych przypadków użycia byłaby funkcja ConcurrentHashMap, która intensywnie wykorzystuje tablicę wewnętrznie. Tablica może być niestabilna, ale na poziomie każdego elementu, sematycy nie mogą być niestabilne. to jeden z powodów powstania automatycznej tablicy.

Answer 5

import java.util.concurrent.atomic.AtomicReferenceArray; 

public class AtomicReferenceArrayExample { 
    AtomicReferenceArray<String> arr = new AtomicReferenceArray<String>(10); 

    public static void main(String... args) { 
     new Thread(new AtomicReferenceArrayExample().new AddThread()).start(); 
     new Thread(new AtomicReferenceArrayExample().new AddThread()).start(); 
    } 

    class AddThread implements Runnable { 
     @Override 
     public void run() { 
      // Sets value at the index 1 
      arr.set(0, "A"); 
      // At index 0, if current reference is "A" then it changes as "B". 
      arr.compareAndSet(0, "A", "B"); 
      // At index 0, if current value is "B", then it is sets as "C". 
      arr.weakCompareAndSet(0, "B", "C"); 
      System.out.println(arr.get(0)); 
     } 
    } 

} 

// Result: 
//  C 
//  C