static final class ConcurrentHashMapV8.ForEachTransformedMappingTask<K,V,U> extends ConcurrentHashMapV8.BulkTask<K,V,java.lang.Void>
ForkJoinTask.AdaptedCallable<T>, ForkJoinTask.AdaptedRunnable<T>, ForkJoinTask.AdaptedRunnableAction, ForkJoinTask.ExceptionNode, ForkJoinTask.RunnableExecuteAction
Modifier and Type | Field and Description |
---|---|
(package private) ConcurrentHashMapV8.Action<? super U> |
action |
(package private) ConcurrentHashMapV8.BiFun<? super K,? super V,? extends U> |
transformer |
baseIndex, baseLimit, baseSize, batch, index, next, tab
completer, pending
CANCELLED, DONE_MASK, EXCEPTIONAL, NORMAL, SIGNAL, SMASK, status
Constructor and Description |
---|
ForEachTransformedMappingTask(ConcurrentHashMapV8.BulkTask<K,V,?> p,
int b,
int i,
int f,
ConcurrentHashMapV8.Node<K,V>[] t,
ConcurrentHashMapV8.BiFun<? super K,? super V,? extends U> transformer,
ConcurrentHashMapV8.Action<? super U> action) |
Modifier and Type | Method and Description |
---|---|
void |
compute()
The main computation performed by this task.
|
advance
addToPendingCount, compareAndSetPendingCount, complete, decrementPendingCountUnlessZero, exec, firstComplete, getCompleter, getPendingCount, getRawResult, getRoot, internalPropagateException, nextComplete, onCompletion, onExceptionalCompletion, propagateCompletion, quietlyCompleteRoot, setPendingCount, setRawResult, tryComplete
adapt, adapt, adapt, cancel, cancelIgnoringExceptions, compareAndSetForkJoinTaskTag, completeExceptionally, doExec, fork, get, get, getException, getForkJoinTaskTag, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpExpungeStaleExceptions, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, peekNextLocalTask, pollNextLocalTask, pollTask, quietlyComplete, quietlyInvoke, quietlyJoin, recordExceptionalCompletion, reinitialize, rethrow, setForkJoinTaskTag, trySetSignal, tryUnfork, uncheckedThrow
final ConcurrentHashMapV8.BiFun<? super K,? super V,? extends U> transformer
final ConcurrentHashMapV8.Action<? super U> action
ForEachTransformedMappingTask(ConcurrentHashMapV8.BulkTask<K,V,?> p, int b, int i, int f, ConcurrentHashMapV8.Node<K,V>[] t, ConcurrentHashMapV8.BiFun<? super K,? super V,? extends U> transformer, ConcurrentHashMapV8.Action<? super U> action)
public final void compute()
CountedCompleter
compute
in class CountedCompleter<java.lang.Void>