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

Class GridCacheAtomicStampedImpl<T,S>

java.lang.Object

org.gridgain.grid.kernal.processors.cache.datastructures.GridCacheAtomicStampedImpl<T,S>

All Implemented Interfaces:

Externalizable, Serializable, GridCacheAtomicStamped<T,S>, GridCacheAtomicStampedEx<T,S>, GridCacheRemovable

public final class GridCacheAtomicStampedImpl<T,S>
extends Object
implements GridCacheAtomicStampedEx<T,S>, Externalizable

Cache atomic stamped implementation.

See Also:

Serialized Form

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
boolean	compareAndSet(T expVal, T newVal, S expStamp, S newStamp) Conditionally sets the new value and new stamp.
GridBiTuple<T,S>	get() Gets both current value and current stamp of atomic stamped.
GridCacheInternalKey	key() Get current atomic stamped key.
String	name() Name of atomic stamped.
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, S stamp) Unconditionally sets the value and the stamp.
S	stamp() Gets current stamp.
String	toString()
T	value() Gets current value.
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

GridCacheAtomicStampedImpl

public GridCacheAtomicStampedImpl()

Empty constructor required by Externalizable.

GridCacheAtomicStampedImpl

public GridCacheAtomicStampedImpl(String name,
                          GridCacheInternalKey key,
                          GridCacheProjection<GridCacheInternalKey,GridCacheAtomicStampedValue<T,S>> atomicView,
                          GridCacheContext ctx)

Default constructor.

Parameters:

name - Atomic stamped name.

key - Atomic stamped key.

atomicView - Atomic projection.

ctx - Cache context.

Method Detail

name

public String name()

Name of atomic stamped.

Specified by:

name in interface GridCacheAtomicStamped<T,S>

Returns:

Name of atomic stamped.

get

public GridBiTuple<T,S> get()
                     throws GridException

Gets both current value and current stamp of atomic stamped.

Specified by:

get in interface GridCacheAtomicStamped<T,S>

Returns:

both current value and current stamp of atomic stamped.

Throws:

GridException - If operation failed.

set

public void set(T val,
       S stamp)
         throws GridException

Unconditionally sets the value and the stamp.

Specified by:

set in interface GridCacheAtomicStamped<T,S>

Parameters:

val - Value.

stamp - Stamp.

Throws:

GridException - If operation failed.

compareAndSet

public boolean compareAndSet(T expVal,
                    T newVal,
                    S expStamp,
                    S newStamp)
                      throws GridException

Conditionally sets the new value and new stamp. They will be set if expVal and expStamp are equal to current value and current stamp respectively.

Specified by:

compareAndSet in interface GridCacheAtomicStamped<T,S>

Parameters:

expVal - Expected value.

newVal - New value.

expStamp - Expected stamp.

newStamp - New stamp.

Returns:

Result of operation execution. If true than value and stamp will be updated.

Throws:

GridException - If operation failed.

stamp

public S stamp()
        throws GridException

Gets current stamp.

Specified by:

stamp in interface GridCacheAtomicStamped<T,S>

Returns:

Current stamp.

Throws:

GridException - If operation failed.

value

public T value()
        throws GridException

Gets current value.

Specified by:

value in interface GridCacheAtomicStamped<T,S>

Returns:

Current value.

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 stamped key.

Specified by:

key in interface GridCacheAtomicStampedEx<T,S>

Returns:

Atomic stamped key.

removed

public boolean removed()

Gets status of atomic.

Specified by:

removed in interface GridCacheAtomicStamped<T,S>

Returns:

true if atomic stamped 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