water

Class TAtomic<T extends Freezable>

java.lang.Object

jsr166y.ForkJoinTask<java.lang.Void>

jsr166y.CountedCompleter

water.H2O.H2OCountedCompleter<T>

water.DTask<T>

water.Atomic<TAtomic<T>>

water.TAtomic<T>

All Implemented Interfaces:

java.io.Serializable, java.lang.Cloneable, java.util.concurrent.Future<java.lang.Void>, Freezable<TAtomic<T>>

Direct Known Subclasses:

IcedInt.AtomicIncrementAndGet

public abstract class TAtomic<T extends Freezable>
extends Atomic<TAtomic<T>>

A typed atomic update.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class water.DTask

DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>, DTask.RemoveCall

Field Summary

Fields inherited from class water.Atomic

_key

Fields inherited from class water.DTask

_ex

Constructor Summary

Constructors

Constructor and Description
TAtomic()
TAtomic(H2O.H2OCountedCompleter completer)

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract T	atomic(T old) Atomically update an old value to a new one.
protected Value	atomic(Value val)
void	onSuccess(T old)
protected void	onSuccess(Value old) Executed on the transaction key's home node after any successful atomic update.

Methods inherited from class water.Atomic

compute2, fork, invoke

Methods inherited from class water.DTask

copyOver, dinvoke, getDException, hasException, logVerbose, onAck, onAckAck, setException

Methods inherited from class water.H2O.H2OCountedCompleter

asBytes, clone, compute, compute1, currThrPriority, frozenType, icer, priority, read, readJSON, reloadFromBytes, write, writeJSON

Methods inherited from class jsr166y.CountedCompleter

__tryComplete, addToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, onCompletion, onExceptionalCompletion, setCompleter, setPendingCount, setRawResult, tryComplete

Methods inherited from class jsr166y.ForkJoinTask

adapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, completeExceptionally, fork, get, get, getException, getForkJoinTaskTag, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, peekNextLocalTask, pollNextLocalTask, pollTask, quietlyComplete, quietlyInvoke, quietlyJoin, reinitialize, setForkJoinTaskTag, tryUnfork

Methods inherited from class java.lang.Object

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

Constructor Detail

TAtomic

public TAtomic()

TAtomic

public TAtomic(H2O.H2OCountedCompleter completer)

Method Detail

atomic

protected abstract T atomic(T old)

Atomically update an old value to a new one.

Parameters:

old - The old value, it may be null. It is a defensive copy.

Returns:

The new value; if null if this atomic update no longer needs to be run

atomic

protected Value atomic(Value val)

Specified by:

atomic in class Atomic<TAtomic<T extends Freezable>>

onSuccess

protected void onSuccess(Value old)

Description copied from class: Atomic

Executed on the transaction key's home node after any successful atomic update. Override this if you need to perform some action after the update succeeds (eg cleanup).

Overrides:

onSuccess in class Atomic<TAtomic<T extends Freezable>>

onSuccess

public void onSuccess(T old)