public class AtomicLongProxy extends AbstractDistributedObject<AtomicLongService> implements AsyncAtomicLong
PARTITIONING_STRATEGY
Constructor and Description |
---|
AtomicLongProxy(String name,
NodeEngine nodeEngine,
AtomicLongService service) |
Modifier and Type | Method and Description |
---|---|
long |
addAndGet(long delta)
Atomically adds the given value to the current value.
|
void |
alter(IFunction<Long,Long> function)
Alters the currently stored value by applying a function on it.
|
long |
alterAndGet(IFunction<Long,Long> function)
Alters the currently stored value by applying a function on it and gets the result.
|
<R> R |
apply(IFunction<Long,R> function)
Applies a function on the value, the actual stored value will not change.
|
InternalCompletableFuture<Long> |
asyncAddAndGet(long delta)
Atomically adds the given value to the current value.
|
InternalCompletableFuture<Void> |
asyncAlter(IFunction<Long,Long> function)
Alters the currently stored value by applying a function on it.
|
InternalCompletableFuture<Long> |
asyncAlterAndGet(IFunction<Long,Long> function)
Alters the currently stored value by applying a function on it and gets the result.
|
<R> InternalCompletableFuture<R> |
asyncApply(IFunction<Long,R> function)
Applies a function on the value, the actual stored value will not change.
|
InternalCompletableFuture<Boolean> |
asyncCompareAndSet(long expect,
long update)
Atomically sets the value to the given updated value
only if the current value
== the expected value. |
InternalCompletableFuture<Long> |
asyncDecrementAndGet()
Atomically decrements the current value by one.
|
InternalCompletableFuture<Long> |
asyncGet()
Gets the current value.
|
InternalCompletableFuture<Long> |
asyncGetAndAdd(long delta)
Atomically adds the given value to the current value.
|
InternalCompletableFuture<Long> |
asyncGetAndAlter(IFunction<Long,Long> function)
Alters the currently stored value by applying a function on it on and gets the old value.
|
InternalCompletableFuture<Long> |
asyncGetAndIncrement()
Atomically increments the current value by one.
|
InternalCompletableFuture<Long> |
asyncGetAndSet(long newValue)
Atomically sets the given value and returns the old value.
|
InternalCompletableFuture<Long> |
asyncIncrementAndGet()
Atomically increments the current value by one.
|
InternalCompletableFuture<Void> |
asyncSet(long newValue)
Atomically sets the given value.
|
boolean |
compareAndSet(long expect,
long update)
Atomically sets the value to the given updated value
only if the current value
== the expected value. |
long |
decrementAndGet()
Atomically decrements the current value by one.
|
long |
get()
Gets the current value.
|
long |
getAndAdd(long delta)
Atomically adds the given value to the current value.
|
long |
getAndAlter(IFunction<Long,Long> function)
Alters the currently stored value by applying a function on it on and gets the old value.
|
long |
getAndIncrement()
Atomically increments the current value by one.
|
long |
getAndSet(long newValue)
Atomically sets the given value and returns the old value.
|
String |
getName()
Returns the name of this IAtomicLong instance.
|
int |
getPartitionId() |
String |
getServiceName()
Returns the service name for this object.
|
long |
incrementAndGet()
Atomically increments the current value by one.
|
void |
set(long newValue)
Atomically sets the given value.
|
String |
toString() |
destroy, equals, getNameAsPartitionAwareData, getNodeEngine, getOperationService, getPartitionId, getPartitionKey, getService, hashCode, invalidate, postDestroy, throwNotActiveException
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
destroy, getPartitionKey
public AtomicLongProxy(String name, NodeEngine nodeEngine, AtomicLongService service)
public String getName()
IAtomicLong
getName
in interface DistributedObject
getName
in interface IAtomicLong
public int getPartitionId()
public String getServiceName()
DistributedObject
getServiceName
in interface DistributedObject
getServiceName
in class AbstractDistributedObject<AtomicLongService>
public long addAndGet(long delta)
IAtomicLong
addAndGet
in interface IAtomicLong
delta
- the value to add to the current valuepublic InternalCompletableFuture<Long> asyncAddAndGet(long delta)
AsyncAtomicLong
asyncAddAndGet
in interface AsyncAtomicLong
delta
- the value to addpublic boolean compareAndSet(long expect, long update)
IAtomicLong
==
the expected value.compareAndSet
in interface IAtomicLong
expect
- the expected valueupdate
- the new valuepublic InternalCompletableFuture<Boolean> asyncCompareAndSet(long expect, long update)
AsyncAtomicLong
==
the expected value.asyncCompareAndSet
in interface AsyncAtomicLong
expect
- the expected valueupdate
- the new valuepublic void set(long newValue)
IAtomicLong
set
in interface IAtomicLong
newValue
- the new valuepublic InternalCompletableFuture<Void> asyncSet(long newValue)
AsyncAtomicLong
asyncSet
in interface AsyncAtomicLong
newValue
- the new valuepublic long getAndSet(long newValue)
IAtomicLong
getAndSet
in interface IAtomicLong
newValue
- the new valuepublic InternalCompletableFuture<Long> asyncGetAndSet(long newValue)
AsyncAtomicLong
asyncGetAndSet
in interface AsyncAtomicLong
newValue
- the new valuepublic long getAndAdd(long delta)
IAtomicLong
getAndAdd
in interface IAtomicLong
delta
- the value to add to the current valuepublic InternalCompletableFuture<Long> asyncGetAndAdd(long delta)
AsyncAtomicLong
asyncGetAndAdd
in interface AsyncAtomicLong
delta
- the value to addpublic long decrementAndGet()
IAtomicLong
decrementAndGet
in interface IAtomicLong
public InternalCompletableFuture<Long> asyncDecrementAndGet()
AsyncAtomicLong
asyncDecrementAndGet
in interface AsyncAtomicLong
public long get()
IAtomicLong
get
in interface IAtomicLong
public InternalCompletableFuture<Long> asyncGet()
AsyncAtomicLong
asyncGet
in interface AsyncAtomicLong
public long incrementAndGet()
IAtomicLong
incrementAndGet
in interface IAtomicLong
public InternalCompletableFuture<Long> asyncIncrementAndGet()
AsyncAtomicLong
asyncIncrementAndGet
in interface AsyncAtomicLong
public long getAndIncrement()
IAtomicLong
getAndIncrement
in interface IAtomicLong
public InternalCompletableFuture<Long> asyncGetAndIncrement()
AsyncAtomicLong
asyncGetAndIncrement
in interface AsyncAtomicLong
public void alter(IFunction<Long,Long> function)
IAtomicLong
alter
in interface IAtomicLong
function
- the function applied to the currently stored valuepublic InternalCompletableFuture<Void> asyncAlter(IFunction<Long,Long> function)
AsyncAtomicLong
asyncAlter
in interface AsyncAtomicLong
function
- the functionpublic long alterAndGet(IFunction<Long,Long> function)
IAtomicLong
alterAndGet
in interface IAtomicLong
function
- the function applied to the currently stored valuepublic InternalCompletableFuture<Long> asyncAlterAndGet(IFunction<Long,Long> function)
AsyncAtomicLong
asyncAlterAndGet
in interface AsyncAtomicLong
function
- the functionpublic long getAndAlter(IFunction<Long,Long> function)
IAtomicLong
getAndAlter
in interface IAtomicLong
function
- the function applied to the currently stored valuepublic InternalCompletableFuture<Long> asyncGetAndAlter(IFunction<Long,Long> function)
AsyncAtomicLong
asyncGetAndAlter
in interface AsyncAtomicLong
function
- the functionpublic <R> R apply(IFunction<Long,R> function)
IAtomicLong
apply
in interface IAtomicLong
function
- the function applied to the value, the value is not changedpublic <R> InternalCompletableFuture<R> asyncApply(IFunction<Long,R> function)
AsyncAtomicLong
asyncApply
in interface AsyncAtomicLong
function
- the functionpublic String toString()
toString
in class AbstractDistributedObject<AtomicLongService>
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.