org.apache.ignite.internal.processors.datastructures

Class GridCacheAtomicLongImpl

java.lang.Object

org.apache.ignite.internal.processors.datastructures.AtomicDataStructureProxy<GridCacheAtomicLongValue>

org.apache.ignite.internal.processors.datastructures.GridCacheAtomicLongImpl

All Implemented Interfaces:

Closeable, Externalizable, Serializable, AutoCloseable, IgniteAtomicLong, IgniteChangeGlobalStateSupport, GridCacheAtomicLongEx, GridCacheRemovable

public final class GridCacheAtomicLongImpl
extends AtomicDataStructureProxy<GridCacheAtomicLongValue>
implements GridCacheAtomicLongEx, IgniteChangeGlobalStateSupport, Externalizable

Cache atomic long implementation.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.datastructures.AtomicDataStructureProxy

cacheView, ctx, key, log, name, rmvd

Constructor Summary

Constructors

Constructor and Description
GridCacheAtomicLongImpl() Empty constructor required by Externalizable.
GridCacheAtomicLongImpl(String name, GridCacheInternalKey key, IgniteInternalCache<GridCacheInternalKey,GridCacheAtomicLongValue> atomicView) Default constructor.

Method Summary

Modifier and Type	Method and Description
long	addAndGet(long l) Adds l and gets current value of atomic long.
void	close() Removes this atomic long.
boolean	compareAndSet(long expVal, long newVal) Atomically compares current value to the expected value, and if they are equal, sets current value to new value.
long	compareAndSetAndGet(long expVal, long newVal)
long	decrementAndGet() Decrements and gets current value of atomic long.
long	get() Gets current value of atomic long.
long	getAndAdd(long l) Gets current value of atomic long and adds l.
long	getAndDecrement() Gets and decrements current value of atomic long.
long	getAndIncrement() Gets and increments current value of atomic long.
long	getAndSet(long l) Gets current value of atomic long and sets new value l of atomic long.
long	incrementAndGet() Increments and gets current value of atomic long.
void	readExternal(ObjectInput in)
String	toString()
void	writeExternal(ObjectOutput out)

Methods inherited from class org.apache.ignite.internal.processors.datastructures.AtomicDataStructureProxy

checkRemoved, invalidateLocalState, key, name, needCheckNotRemoved, onActivate, onDeActivate, onRemoved, removed, restart, suspend

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.processors.datastructures.GridCacheAtomicLongEx

key

Methods inherited from interface org.apache.ignite.internal.processors.datastructures.GridCacheRemovable

needCheckNotRemoved, onRemoved, restart, suspend

Methods inherited from interface org.apache.ignite.IgniteAtomicLong

name, removed

Methods inherited from interface org.apache.ignite.internal.processors.cluster.IgniteChangeGlobalStateSupport

onActivate, onDeActivate

Constructor Detail

GridCacheAtomicLongImpl

public GridCacheAtomicLongImpl()

Empty constructor required by Externalizable.

GridCacheAtomicLongImpl

public GridCacheAtomicLongImpl(String name,
                               GridCacheInternalKey key,
                               IgniteInternalCache<GridCacheInternalKey,GridCacheAtomicLongValue> atomicView)

Default constructor.

Parameters:

name - Atomic long name.

key - Atomic long key.

atomicView - Atomic projection.

Method Detail

get

public long get()

Gets current value of atomic long.

Specified by:

get in interface IgniteAtomicLong

Returns:

Current value of atomic long.

incrementAndGet

public long incrementAndGet()

Increments and gets current value of atomic long.

Specified by:

incrementAndGet in interface IgniteAtomicLong

Returns:

Value.

getAndIncrement

public long getAndIncrement()

Gets and increments current value of atomic long.

Specified by:

getAndIncrement in interface IgniteAtomicLong

Returns:

Value.

addAndGet

public long addAndGet(long l)

Adds l and gets current value of atomic long.

Specified by:

addAndGet in interface IgniteAtomicLong

Parameters:

l - Number which will be added.

Returns:

Value.

getAndAdd

public long getAndAdd(long l)

Gets current value of atomic long and adds l.

Specified by:

getAndAdd in interface IgniteAtomicLong

Parameters:

l - Number which will be added.

Returns:

Value.

decrementAndGet

public long decrementAndGet()

Decrements and gets current value of atomic long.

Specified by:

decrementAndGet in interface IgniteAtomicLong

Returns:

Value.

getAndDecrement

public long getAndDecrement()

Gets and decrements current value of atomic long.

Specified by:

getAndDecrement in interface IgniteAtomicLong

Returns:

Value.

getAndSet

public long getAndSet(long l)

Gets current value of atomic long and sets new value l of atomic long.

Specified by:

getAndSet in interface IgniteAtomicLong

Parameters:

l - New value of atomic long.

Returns:

Value.

compareAndSet

public boolean compareAndSet(long expVal,
                             long newVal)

Atomically compares current value to the expected value, and if they are equal, sets current value to new value.

Specified by:

compareAndSet in interface IgniteAtomicLong

Parameters:

expVal - Expected atomic long's value.

newVal - New atomic long's value to set if current value equal to expected value.

Returns:

True if comparison succeeded, false otherwise.

compareAndSetAndGet

public long compareAndSetAndGet(long expVal,
                                long newVal)

Parameters:

expVal - Expected value.

newVal - New value.

Returns:

Old value.

close

public void close()

Removes this atomic long.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface IgniteAtomicLong

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