public abstract class Atomic<T extends Atomic> extends DTask<T>
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>, DTask.RemoveCall
Modifier and Type | Field and Description |
---|---|
protected Key |
_key |
_ex, _modifiesInputs
Constructor and Description |
---|
Atomic() |
Atomic(H2O.H2OCountedCompleter completer) |
Modifier and Type | Method and Description |
---|---|
protected abstract Value |
atomic(Value val) |
protected void |
compute2()
Override to specify actual work to do
|
RPC<Atomic<T>> |
fork(Key key) |
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.
|
protected byte |
priority() |
copyOver, dinvoke, getDException, hasException, logVerbose, onAck, onAckAck, setException
clone, compute, frozenType, icer, nextThrPriority, onExceptionalCompletion, read_impl, read, readJSON_impl, readJSON, write_impl, write, writeHTML_impl, writeHTML, writeJSON_impl, writeJSON
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
protected Key _key
public Atomic()
public Atomic(H2O.H2OCountedCompleter completer)
protected void onSuccess(Value old)
protected final void compute2()
H2O.H2OCountedCompleter
compute2
in class H2O.H2OCountedCompleter<T extends Atomic>
protected byte priority()
priority
in class H2O.H2OCountedCompleter<T extends Atomic>