Package com.oracle.coherence.concurrent.atomic

Class AsyncLocalAtomicStampedReference<V>

java.lang.Object

com.oracle.coherence.concurrent.atomic.AsyncLocalAtomicStampedReference<V>

Type Parameters:

V - the type of object referred to by this reference

All Implemented Interfaces:

AsyncAtomicStampedReference<V>

public class AsyncLocalAtomicStampedReference<V>
extends Object
implements AsyncAtomicStampedReference<V>

Local implementation of AsyncAtomicStampedReference interface, that simply wraps java.util.concurrent.atomic.AtomicStampedReference instance and returns an already completed future from each method.

Author:

Aleks Seovic 2020.12.09

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AsyncLocalAtomicStampedReference(AtomicStampedReference<V> value)	Construct AsyncLocalAtomicStampedReference instance.

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Boolean>	attemptStamp(V expectedReference, int nNewStamp)	Atomically sets the value of the stamp to the given update value if the current reference is equal to the expected reference.
CompletableFuture<Boolean>	compareAndSet(V expectedReference, V newReference, int nExpectedStamp, int newStamp)	Atomically sets the value of both the reference and stamp to the given update values if the current reference is equal to the expected reference and the current stamp is equal to the expected stamp.
CompletableFuture<V>	get(int[] iaStampHolder)	Returns the current values of both the reference and the stamp.
CompletableFuture<V>	getReference()	Returns the current value of the reference.
CompletableFuture<Integer>	getStamp()	Returns the current value of the stamp.
CompletableFuture<Void>	set(V newReference, int nNewStamp)	Unconditionally sets the value of both the reference and stamp.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

AsyncLocalAtomicStampedReference

protected AsyncLocalAtomicStampedReference(AtomicStampedReference<V> value)

Construct AsyncLocalAtomicStampedReference instance.

Parameters:

value - wrapped value

Method Details

getReference

public CompletableFuture<V> getReference()

Description copied from interface: AsyncAtomicStampedReference

Returns the current value of the reference.

Specified by:

getReference in interface AsyncAtomicStampedReference<V>

Returns:

the current value of the reference

getStamp

public CompletableFuture<Integer> getStamp()

Description copied from interface: AsyncAtomicStampedReference

Returns the current value of the stamp.

Specified by:

getStamp in interface AsyncAtomicStampedReference<V>

Returns:

the current value of the stamp

get

public CompletableFuture<V> get(int[] iaStampHolder)

Description copied from interface: AsyncAtomicStampedReference

Returns the current values of both the reference and the stamp. Typical usage is int[1] holder; ref = v.get(holder); .

Specified by:

get in interface AsyncAtomicStampedReference<V>

Parameters:

iaStampHolder - an array of size of at least one. On return, stampHolder[0] will hold the value of the stamp

Returns:

the current value of the reference

compareAndSet

public CompletableFuture<Boolean> compareAndSet(V expectedReference,
 V newReference,
 int nExpectedStamp,
 int newStamp)

Description copied from interface: AsyncAtomicStampedReference

Atomically sets the value of both the reference and stamp to the given update values if the current reference is equal to the expected reference and the current stamp is equal to the expected stamp.

Specified by:

compareAndSet in interface AsyncAtomicStampedReference<V>

Parameters:

expectedReference - the expected value of the reference

newReference - the new value for the reference

nExpectedStamp - the expected value of the stamp

newStamp - the new value for the stamp

Returns:

true if successful

set

public CompletableFuture<Void> set(V newReference,
 int nNewStamp)

Description copied from interface: AsyncAtomicStampedReference

Unconditionally sets the value of both the reference and stamp.

Specified by:

set in interface AsyncAtomicStampedReference<V>

Parameters:

newReference - the new value for the reference

nNewStamp - the new value for the stamp

Returns:

a CompletableFuture that can be used to determine whether the operation completed

attemptStamp

public CompletableFuture<Boolean> attemptStamp(V expectedReference,
 int nNewStamp)

Description copied from interface: AsyncAtomicStampedReference

Atomically sets the value of the stamp to the given update value if the current reference is equal to the expected reference. Any given invocation of this operation may fail (return false) spuriously, but repeated invocation when the current value holds the expected value and no other thread is also attempting to set the value will eventually succeed.

Specified by:

attemptStamp in interface AsyncAtomicStampedReference<V>

Parameters:

expectedReference - the expected value of the reference

nNewStamp - the new value for the stamp

Returns:

true if successful

toString

public String toString()

Overrides:

toString in class Object