hu.akarnokd.reactive4java.util

Class Atomics

java.lang.Object

hu.akarnokd.reactive4java.util.Atomics

public final class Atomics
extends java.lang.Object

Utility classes to perform some AtomicXYZ related operations not supported by the classes themselves.

Since:

0.97

Method Summary

Modifier and Type	Method and Description
static boolean	compareExchange(java.util.concurrent.atomic.AtomicBoolean ref, boolean compareWith, boolean newValue) Atomically compares the content of ref with the compareWith value and replaces it with the newValue if they equal.
static int	compareExchange(java.util.concurrent.atomic.AtomicInteger ref, int compareWith, int newValue) Atomically compares the content of ref with the compareWith value and replaces it with the newValue if they equal.
static long	compareExchange(java.util.concurrent.atomic.AtomicLong ref, long compareWith, long newValue) Atomically compares the content of ref with the compareWith value and replaces it with the newValue if they equal.
static <T> T	compareExchange(java.util.concurrent.atomic.AtomicReference<T> ref, T compareWith, T newValue) Atomically compares the content of ref with the compareWith value by using nullsafe object equality and replaces it with the newValue if they equal.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

compareExchange

public static <T> T compareExchange(@Nonnull
                                    java.util.concurrent.atomic.AtomicReference<T> ref,
                                    T compareWith,
                                    T newValue)

Atomically compares the content of ref with the compareWith value by using nullsafe object equality and replaces it with the newValue if they equal. The method returns the old value of ref regardless of whether the exchange actually happened.

Type Parameters:

T - the element type

Parameters:

ref - the target of the exchange

compareWith - the value to compare against

newValue - the the new value to replace with

Returns:

the old value of the ref

compareExchange

public static boolean compareExchange(@Nonnull
                                      java.util.concurrent.atomic.AtomicBoolean ref,
                                      boolean compareWith,
                                      boolean newValue)

Atomically compares the content of ref with the compareWith value and replaces it with the newValue if they equal. The method returns the old value of ref regardless of whether the exchange actually happened.

Parameters:

ref - the target of the exchange

compareWith - the value to compare against

newValue - the the new value to replace with

Returns:

the old value of the ref

compareExchange

public static int compareExchange(@Nonnull
                                  java.util.concurrent.atomic.AtomicInteger ref,
                                  int compareWith,
                                  int newValue)

Atomically compares the content of ref with the compareWith value and replaces it with the newValue if they equal. The method returns the old value of ref regardless of whether the exchange actually happened.

Parameters:

ref - the target of the exchange

compareWith - the value to compare against

newValue - the the new value to replace with

Returns:

the old value of the ref

compareExchange

public static long compareExchange(@Nonnull
                                   java.util.concurrent.atomic.AtomicLong ref,
                                   long compareWith,
                                   long newValue)

Atomically compares the content of ref with the compareWith value and replaces it with the newValue if they equal. The method returns the old value of ref regardless of whether the exchange actually happened.

Parameters:

ref - the target of the exchange

compareWith - the value to compare against

newValue - the the new value to replace with

Returns:

the old value of the ref