public abstract static class H2O.H2OCountedCompleter<T extends H2O.H2OCountedCompleter> extends CountedCompleter implements java.lang.Cloneable, Freezable
| Modifier | Constructor and Description |
|---|---|
|
H2O.H2OCountedCompleter() |
protected |
H2O.H2OCountedCompleter(H2O.H2OCountedCompleter completer) |
| Modifier and Type | Method and Description |
|---|---|
T |
clone()
Clone, without the annoying exception
|
void |
compute()
The main computation performed by this task.
|
protected abstract void |
compute2() |
int |
frozenType()
Cluster-wide unique small dense integer specifying your class type.
|
protected Icer<T> |
icer() |
protected byte |
nextThrPriority() |
boolean |
onExceptionalCompletion(java.lang.Throwable ex,
CountedCompleter caller)
Performs an action when method
ForkJoinTask.completeExceptionally(java.lang.Throwable)
is invoked or method CountedCompleter.compute() throws an exception, and
this task has not otherwise already completed normally. |
protected byte |
priority() |
T |
read_impl(AutoBuffer ab) |
T |
read(AutoBuffer ab)
Read from the AutoBuffer overwriting your own fields, returning yourself 'this'.
|
T |
readJSON_impl(AutoBuffer ab) |
T |
readJSON(AutoBuffer ab)
Read from the AutoBuffer overwriting your own fields, returning yourself 'this'.
|
AutoBuffer |
write_impl(AutoBuffer ab) |
AutoBuffer |
write(AutoBuffer ab)
Write this Freezable onto the AutoBuffer.
|
DocGen.HTML |
writeHTML_impl(DocGen.HTML ab) |
DocGen.HTML |
writeHTML(DocGen.HTML ab)
Write this Freezable onto the AutoBuffer.
|
AutoBuffer |
writeJSON_impl(AutoBuffer ab) |
AutoBuffer |
writeJSON(AutoBuffer ab)
Write this Freezable onto the AutoBuffer.
|
addToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, onCompletion, 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 H2O.H2OCountedCompleter()
protected H2O.H2OCountedCompleter(H2O.H2OCountedCompleter completer)
public final void compute()
CountedCompletercompute in class CountedCompleterprotected abstract void compute2()
public boolean onExceptionalCompletion(java.lang.Throwable ex,
CountedCompleter caller)
CountedCompleterForkJoinTask.completeExceptionally(java.lang.Throwable)
is invoked or method CountedCompleter.compute() throws an exception, and
this task has not otherwise already completed normally. On
entry to this method, this task ForkJoinTask.isCompletedAbnormally(). The return value of this
method controls further propagation: If true and this
task has a completer, then this completer is also completed
exceptionally. The default implementation of this method does
nothing except return true.onExceptionalCompletion in class CountedCompleterex - the exceptioncaller - the task invoking this method (which may
be this task itself).protected byte priority()
public final T clone()
Freezableprotected final byte nextThrPriority()
public final AutoBuffer write(AutoBuffer ab)
Freezablepublic final AutoBuffer writeJSON(AutoBuffer ab)
Freezablepublic final DocGen.HTML writeHTML(DocGen.HTML ab)
Freezablepublic final T read(AutoBuffer ab)
Freezablepublic final T readJSON(AutoBuffer ab)
Freezablepublic final int frozenType()
FreezablefrozenType in interface Freezablepublic AutoBuffer write_impl(AutoBuffer ab)
write_impl in interface Freezablepublic T read_impl(AutoBuffer ab)
public AutoBuffer writeJSON_impl(AutoBuffer ab)
writeJSON_impl in interface Freezablepublic T readJSON_impl(AutoBuffer ab)
readJSON_impl in interface Freezablepublic DocGen.HTML writeHTML_impl(DocGen.HTML ab)
writeHTML_impl in interface Freezable