Package jsr166.impl

Class ContextualCancellableCompleterBoundedAction

java.lang.Object

java.util.concurrent.ForkJoinTask<T>

java.util.concurrent.CountedCompleter<T>

com.qfs.concurrent.cancellable.impl.CancellableCountedCompleter<T>

com.qfs.concurrent.cancellable.impl.CancellableCountedCompleterWithChildren<T>

com.quartetfs.biz.pivot.context.impl.ContextualCancellableCountedCompleter<Void>

jsr166.impl.ContextualCancellableCompleterBoundedAction

All Implemented Interfaces:

ICancellableTask, Serializable, Future<Void>

public class ContextualCancellableCompleterBoundedAction
extends ContextualCancellableCountedCompleter<Void>

A contextual version of a BoundedAction using CancellableCountedCompleters.

Author:

ActiveViam

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ContextualCancellableCompleterBoundedAction.CompletableBoundedAction	An action to be executed asynchronously on some data that can be divided into ranges.

Field Summary

Fields inherited from class com.qfs.concurrent.cancellable.impl.CancellableCountedCompleterWithChildren

NEWLINE

Fields inherited from class com.qfs.concurrent.cancellable.impl.CancellableCountedCompleter

WHATEVER_POOL

Constructor Summary

Constructors

Constructor	Description
ContextualCancellableCompleterBoundedAction(CountedCompleter<?> parent, IContext contextToSet, ContextualCancellableCompleterBoundedAction.CompletableBoundedAction action)	Constructor.

Method Summary

Methods inherited from class com.qfs.concurrent.cancellable.impl.CancellableCountedCompleterWithChildren

addChild, addChild, getActiveChildren, getChildren, getOrCreateChildrenList, hasCompletedWork, indent, printPendingCompleters, removeChild, safeDecrementPendingCountUnlessZero, visitCompletersRecursively

Methods inherited from class com.qfs.concurrent.cancellable.impl.CancellableCountedCompleter

cancel, cancel, checkInterruption, compute, getInterruptor, getPreferredCompletionPoolId, onCompletion, setPreferredCompletionPoolId

Methods inherited from class java.util.concurrent.CountedCompleter

addToPendingCount, compareAndSetPendingCount, complete, decrementPendingCountUnlessZero, firstComplete, getCompleter, getPendingCount, getRawResult, getRoot, helpComplete, nextComplete, onExceptionalCompletion, propagateCompletion, quietlyCompleteRoot, setPendingCount, tryComplete

Methods inherited from class java.util.concurrent.ForkJoinTask

adapt, adapt, adapt, compareAndSetForkJoinTaskTag, completeExceptionally, fork, get, get, getException, getForkJoinTaskTag, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, quietlyComplete, quietlyInvoke, quietlyJoin, reinitialize, setForkJoinTaskTag, tryUnfork

Methods inherited from class java.lang.Object

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

Constructor Details

ContextualCancellableCompleterBoundedAction

public ContextualCancellableCompleterBoundedAction(CountedCompleter<?> parent,
 IContext contextToSet,
 ContextualCancellableCompleterBoundedAction.CompletableBoundedAction action)

Constructor.

Parameters:

parent - Our parent completer

contextToSet - The context to snapshot and restore

action - The action to executed