water

Class H2O.H2OCountedCompleter<T extends H2O.H2OCountedCompleter>

java.lang.Object

jsr166y.ForkJoinTask<java.lang.Void>

jsr166y.CountedCompleter

water.H2O.H2OCountedCompleter<T>

All Implemented Interfaces:

java.io.Serializable, java.lang.Cloneable, java.util.concurrent.Future<java.lang.Void>

Direct Known Subclasses:

DTask, Frame.FrameIdenticalTask, FrameCreator, FrameExtractor, FrameSplitter, GLM2.ParallelGLMs, H2O.H2OCallback, H2O.H2OEmptyCompleter, Handler, LSMSolver.ADMMSolver.ParallelSolver, NetworkTest.NetworkTester, ParseDataset2.ParserFJTask, RebalanceDataSet, Tree

Enclosing class:

H2O

public abstract static class H2O.H2OCountedCompleter<T extends H2O.H2OCountedCompleter>
extends jsr166y.CountedCompleter
implements java.lang.Cloneable

See Also:

Serialized Form

Constructor Summary

Constructors

Modifier	Constructor and Description
	H2O.H2OCountedCompleter()
protected	H2O.H2OCountedCompleter(H2O.H2OCountedCompleter completer)

Method Summary

Methods

Modifier and Type	Method and Description
T	clone()
void	compute() The main computation performed by this task.
abstract void	compute2()
boolean	onExceptionalCompletion(java.lang.Throwable ex, jsr166y.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.
byte	priority()

Methods inherited from class jsr166y.CountedCompleter

addToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, onCompletion, setCompleter, setPendingCount, setRawResult, tryComplete

Methods inherited from class jsr166y.ForkJoinTask

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

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

H2O.H2OCountedCompleter

public H2O.H2OCountedCompleter()

H2O.H2OCountedCompleter

protected H2O.H2OCountedCompleter(H2O.H2OCountedCompleter completer)

Method Detail

compute

public final void compute()

Description copied from class: jsr166y.CountedCompleter

The main computation performed by this task.

Specified by:

compute in class jsr166y.CountedCompleter

compute2

public abstract void compute2()

onExceptionalCompletion

public boolean onExceptionalCompletion(java.lang.Throwable ex,
                              jsr166y.CountedCompleter caller)

Description copied from class: jsr166y.CountedCompleter

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. 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.

Overrides:

onExceptionalCompletion in class jsr166y.CountedCompleter

Parameters:

ex - the exception

caller - the task invoking this method (which may be this task itself).

Returns:

true if this exception should be propagated to this tasks completer, if one exists.

priority

public byte priority()

clone

public T clone()

Overrides:

clone in class java.lang.Object