org.gridgain.grid.kernal.processors.cache.datastructures

Class GridCacheAtomicReferenceImpl<T>

java.lang.Object

org.gridgain.grid.kernal.processors.cache.datastructures.GridCacheAtomicReferenceImpl<T>

All Implemented Interfaces:

Externalizable, Serializable, GridCacheAtomicReference<T>, GridCacheAtomicReferenceEx<T>, GridCacheRemovable

public final class GridCacheAtomicReferenceImpl<T>
extends Object
implements GridCacheAtomicReferenceEx<T>, Externalizable

Cache atomic reference implementation.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GridCacheAtomicReferenceImpl() Empty constructor required by Externalizable.
GridCacheAtomicReferenceImpl(String name, GridCacheInternalKey key, GridCacheProjection<GridCacheInternalKey,GridCacheAtomicReferenceValue<T>> atomicView, GridCacheContext ctx) Default constructor.

Method Summary

Methods

Modifier and Type	Method and Description
boolean	compareAndSet(T expVal, T newVal) Conditionally sets the new value.
T	get() Gets current value of an atomic reference.
GridCacheInternalKey	key() Get current atomic reference key.
String	name() Name of atomic reference.
void	onInvalid(Exception err)
boolean	onRemoved() Set status of data structure as removed.
void	readExternal(ObjectInput in)
boolean	removed() Gets status of atomic.
void	set(T val) Unconditionally sets the value.
String	toString()
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

GridCacheAtomicReferenceImpl

public GridCacheAtomicReferenceImpl()

Empty constructor required by Externalizable.

GridCacheAtomicReferenceImpl

public GridCacheAtomicReferenceImpl(String name,
                            GridCacheInternalKey key,
                            GridCacheProjection<GridCacheInternalKey,GridCacheAtomicReferenceValue<T>> atomicView,
                            GridCacheContext ctx)

Default constructor.

Parameters:

name - Atomic reference name.

key - Atomic reference key.

atomicView - Atomic projection.

ctx - Cache context.

Method Detail

name

public String name()

Name of atomic reference.

Specified by:

name in interface GridCacheAtomicReference<T>

Returns:

Name of an atomic reference.

get

public T get()
      throws GridException

Gets current value of an atomic reference.

Specified by:

get in interface GridCacheAtomicReference<T>

Returns:

current value of an atomic reference.

Throws:

GridException - If operation failed.

set

public void set(T val)
         throws GridException

Unconditionally sets the value.

Specified by:

set in interface GridCacheAtomicReference<T>

Parameters:

val - Value.

Throws:

GridException - If operation failed.

compareAndSet

public boolean compareAndSet(T expVal,
                    T newVal)
                      throws GridException

Conditionally sets the new value. That will be set if expVal is equal to current value respectively.

Specified by:

compareAndSet in interface GridCacheAtomicReference<T>

Parameters:

expVal - Expected value.

newVal - New value.

Returns:

Result of operation execution. If true than value have been updated.

Throws:

GridException - If operation failed.

onRemoved

public boolean onRemoved()

Set status of data structure as removed.

Specified by:

onRemoved in interface GridCacheRemovable

Returns:

Current status.

onInvalid

public void onInvalid(@Nullable
             Exception err)

Specified by:

onInvalid in interface GridCacheRemovable

Parameters:

err - Error which cause data structure to become invalid.

key

public GridCacheInternalKey key()

Get current atomic reference key.

Specified by:

key in interface GridCacheAtomicReferenceEx<T>

Returns:

Atomic reference key.

removed

public boolean removed()

Gets status of atomic.

Specified by:

removed in interface GridCacheAtomicReference<T>

Returns:

true if an atomic reference was removed from cache, false otherwise.

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

toString

public String toString()

Overrides:

toString in class Object