static final class EquivalentConcurrentHashMapV8.ForEachEntryTask<K,V> extends EquivalentConcurrentHashMapV8.BulkTask<K,V,java.lang.Void>
ForkJoinTask.AdaptedCallable<T>, ForkJoinTask.AdaptedRunnable<T>, ForkJoinTask.AdaptedRunnableAction, ForkJoinTask.ExceptionNode
Modifier and Type | Field and Description |
---|---|
(package private) EquivalentConcurrentHashMapV8.Action<? super java.util.Map.Entry<K,V>> |
action |
baseIndex, baseLimit, baseSize, batch, index, next, tab
completer, pending
CANCELLED, DONE_MASK, EXCEPTIONAL, NORMAL, SIGNAL, SMASK, status
Constructor and Description |
---|
EquivalentConcurrentHashMapV8.ForEachEntryTask(EquivalentConcurrentHashMapV8.BulkTask<K,V,?> p,
int b,
int i,
int f,
EquivalentConcurrentHashMapV8.Node<K,V>[] t,
EquivalentConcurrentHashMapV8.Action<? super java.util.Map.Entry<K,V>> 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 EquivalentConcurrentHashMapV8.Action<? super java.util.Map.Entry<K,V>> action
EquivalentConcurrentHashMapV8.ForEachEntryTask(EquivalentConcurrentHashMapV8.BulkTask<K,V,?> p, int b, int i, int f, EquivalentConcurrentHashMapV8.Node<K,V>[] t, EquivalentConcurrentHashMapV8.Action<? super java.util.Map.Entry<K,V>> action)
public final void compute()
CountedCompleter
compute
in class CountedCompleter<java.lang.Void>