public abstract class Atomic<T extends Atomic> extends DTask
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Iced>
Constructor and Description |
---|
Atomic() |
Atomic(H2O.H2OCountedCompleter completer) |
Modifier and Type | Method and Description |
---|---|
abstract Value |
atomic(Value val) |
void |
compute2() |
RPC<Atomic<T>> |
fork(Key key) |
T |
invoke(Key key)
Block until it completes, even if run remotely
|
void |
onSuccess(Value old)
Executed on the transaction key's home node after any successful
atomic update.
|
byte |
priority() |
copyOver, dinvoke, frozenType, getDException, hasException, logVerbose, newInstance, onAck, onAckAck, read, setException, toDocField, write, writeJSONFields
clone, compute, onExceptionalCompletion
addToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, onCompletion, setCompleter, setPendingCount, setRawResult, tryComplete
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
public Key _key
public Atomic()
public Atomic(H2O.H2OCountedCompleter completer)
public void onSuccess(Value old)
public final void compute2()
compute2
in class H2O.H2OCountedCompleter
public byte priority()
priority
in class H2O.H2OCountedCompleter