public abstract class Atomic<T extends Atomic> extends DTask<T>
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>, DTask.RemoveCall
Constructor and Description |
---|
Atomic() |
Atomic(H2O.H2OCountedCompleter completer) |
Modifier and Type | Method and Description |
---|---|
protected abstract Value |
atomic(Value val) |
void |
compute2()
Override compute3() with actual work without having to worry about tryComplete()
|
RPC<Atomic<T>> |
fork(Key key) |
Atomic<T> |
invoke(Key key)
Block until it completes, even if run remotely
|
protected void |
onSuccess(Value old)
Executed on the transaction key's home node after any successful
atomic update.
|
copyOver, dinvoke, getDException, hasException, logVerbose, onAck, onAckAck, setException
asBytes, clone, compute, compute1, currThrPriority, frozenType, icer, priority, read, readJSON, reloadFromBytes, write, writeJSON
__tryComplete, addToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, onCompletion, onExceptionalCompletion, setCompleter, setPendingCount, setRawResult, tryComplete
adapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, completeExceptionally, fork, get, 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
protected Key _key
public Atomic()
public Atomic(H2O.H2OCountedCompleter completer)
protected void onSuccess(Value old)
public final void compute2()
H2O.H2OCountedCompleter
compute2
in class H2O.H2OCountedCompleter<T extends Atomic>