Параллелизм Java - класс AtomicReference
Класс java.util.concurrent.atomic.AtomicReference предоставляет операции с базовой ссылкой на объект, которые можно читать и записывать атомарно, а также содержит расширенные атомарные операции. AtomicReference поддерживает атомарные операции с базовой переменной ссылки на объект. У него есть методы получения и установки, которые работают как чтение и запись для изменчивых переменных. То есть набор имеет отношение «происходит до» с любым последующим получением той же переменной. Атомарный метод compareAndSet также имеет эти функции согласованности памяти.
Методы AtomicReference
Ниже приводится список важных методов, доступных в классе AtomicReference.
Sr. No. | Метод и описание |
---|---|
1 | public boolean compareAndSet(V expect, V update) Атомарно устанавливает значение для данного обновленного значения, если текущее значение == ожидаемое значение. |
2 | public boolean get() Возвращает текущее значение. |
3 | public boolean getAndSet(V newValue) Атомарно устанавливает данное значение и возвращает предыдущее значение. |
4 | public void lazySet(V newValue) В конце концов устанавливается на заданное значение. |
5 | public void set(V newValue) Безоговорочно устанавливается на заданное значение. |
6 | public String toString() Возвращает строковое представление текущего значения. |
7 | public boolean weakCompareAndSet(V expect, V update) Атомарно устанавливает значение для данного обновленного значения, если текущее значение == ожидаемое значение. |
пример
Следующая программа TestThread показывает использование переменной AtomicReference в среде на основе потоков.
import java.util.concurrent.atomic.AtomicReference;
public class TestThread {
private static String message = "hello";
private static AtomicReference<String> atomicReference;
public static void main(final String[] arguments) throws InterruptedException {
atomicReference = new AtomicReference<String>(message);
new Thread("Thread 1") {
public void run() {
atomicReference.compareAndSet(message, "Thread 1");
message = message.concat("-Thread 1!");
};
}.start();
System.out.println("Message is: " + message);
System.out.println("Atomic Reference of Message is: " + atomicReference.get());
}
}
Это даст следующий результат.
Вывод
Message is: hello
Atomic Reference of Message is: Thread 1