public abstract static class DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed> extends DTask<DTask.DKeyTask>
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>, DTask.RemoveCall
Constructor and Description |
---|
DKeyTask(H2O.H2OCountedCompleter cmp,
Key k) |
Modifier and Type | Method and Description |
---|---|
void |
compute2()
Override compute3() with actual work without having to worry about tryComplete()
|
T |
invokeTask()
Convenience blocking submit to work queues
|
protected abstract void |
map(V v)
Override map(); will be run on Key's home node
|
void |
onCompletion(CountedCompleter cc)
Performs an action when method
CountedCompleter.tryComplete() is invoked
and there are no pending counts, or when the unconditional
method CountedCompleter.complete(java.lang.Void) is invoked. |
void |
submitTask()
Convenience non-blocking submit to work queues
|
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, 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
public DKeyTask(H2O.H2OCountedCompleter cmp, Key k)
protected abstract void map(V v)
public final void compute2()
H2O.H2OCountedCompleter
compute2
in class H2O.H2OCountedCompleter<DTask.DKeyTask>
public final void onCompletion(CountedCompleter cc)
CountedCompleter
CountedCompleter.tryComplete()
is invoked
and there are no pending counts, or when the unconditional
method CountedCompleter.complete(java.lang.Void)
is invoked. By default, this method
does nothing.onCompletion
in class CountedCompleter
cc
- the task invoking this method (which may
be this task itself).public void submitTask()
public T invokeTask()