public abstract static class H2O.H2OCallback<T extends H2O.H2OCountedCompleter> extends H2O.H2OCountedCompleter
| Constructor and Description |
|---|
H2OCallback() |
H2OCallback(H2O.H2OCountedCompleter cc) |
| Modifier and Type | Method and Description |
|---|---|
abstract void |
callback(T t) |
void |
compute2()
Override compute3() with actual work without having to worry about tryComplete()
|
void |
onCompletion(CountedCompleter caller)
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. |
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, tryCompleteadapt, 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, tryUnforkpublic H2OCallback()
public H2OCallback(H2O.H2OCountedCompleter cc)
public void compute2()
H2O.H2OCountedCompletercompute2 in class H2O.H2OCountedCompleterpublic void onCompletion(CountedCompleter caller)
CountedCompleterCountedCompleter.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 CountedCompletercaller - the task invoking this method (which may
be this task itself).public abstract void callback(T t)