Package | Description |
---|---|
alluxio.concurrent.jsr |
Modifier and Type | Method and Description |
---|---|
CountedCompleter<?> |
CountedCompleter.firstComplete()
If this task's pending count is zero, returns this task; otherwise decrements its pending count
and returns
null . |
CountedCompleter<?> |
CountedCompleter.getCompleter()
Returns the completer established in this task's constructor, or
null if none. |
CountedCompleter<?> |
CountedCompleter.getRoot()
Returns the root of the current computation; i.e., this task if it has no completer, else its
completer's root.
|
CountedCompleter<?> |
CountedCompleter.nextComplete()
If this task does not have a completer, invokes
ForkJoinTask.quietlyComplete() and
returns null . |
Modifier and Type | Method and Description |
---|---|
void |
CountedCompleter.onCompletion(CountedCompleter<?> caller)
Performs an action when method
tryComplete() is invoked and the pending count is zero,
or when the unconditional method complete(T) is invoked. |
boolean |
CountedCompleter.onExceptionalCompletion(Throwable ex,
CountedCompleter<?> caller)
Performs an action when method
ForkJoinTask.completeExceptionally(Throwable) is invoked or method
compute() throws an exception, and this task has not already otherwise completed
normally. |
Constructor and Description |
---|
CountedCompleter(CountedCompleter<?> completer)
Creates a new CountedCompleter with the given completer and an initial pending count of zero.
|
CountedCompleter(CountedCompleter<?> completer,
int initialPendingCount)
Creates a new CountedCompleter with the given completer and initial pending count.
|
Copyright © 2023. All Rights Reserved.