static final class EquivalentConcurrentHashMapV8.ReduceEntriesTask<K,V> extends EquivalentConcurrentHashMapV8.BulkTask<K,V,java.util.Map.Entry<K,V>>
ForkJoinTask.AdaptedCallable<T>, ForkJoinTask.AdaptedRunnable<T>, ForkJoinTask.AdaptedRunnableAction, ForkJoinTask.ExceptionNode
Modifier and Type | Field and Description |
---|---|
(package private) EquivalentConcurrentHashMapV8.ReduceEntriesTask<K,V> |
nextRight |
(package private) EquivalentConcurrentHashMapV8.BiFun<java.util.Map.Entry<K,V>,java.util.Map.Entry<K,V>,? extends java.util.Map.Entry<K,V>> |
reducer |
(package private) java.util.Map.Entry<K,V> |
result |
(package private) EquivalentConcurrentHashMapV8.ReduceEntriesTask<K,V> |
rights |
baseIndex, baseLimit, baseSize, batch, index, next, tab
completer, pending
CANCELLED, DONE_MASK, EXCEPTIONAL, NORMAL, SIGNAL, SMASK, status
Constructor and Description |
---|
EquivalentConcurrentHashMapV8.ReduceEntriesTask(EquivalentConcurrentHashMapV8.BulkTask<K,V,?> p,
int b,
int i,
int f,
EquivalentConcurrentHashMapV8.Node<K,V>[] t,
EquivalentConcurrentHashMapV8.ReduceEntriesTask<K,V> nextRight,
EquivalentConcurrentHashMapV8.BiFun<java.util.Map.Entry<K,V>,java.util.Map.Entry<K,V>,? extends java.util.Map.Entry<K,V>> reducer) |
Modifier and Type | Method and Description |
---|---|
void |
compute()
The main computation performed by this task.
|
java.util.Map.Entry<K,V> |
getRawResult()
Returns the result of the computation.
|
advance
addToPendingCount, compareAndSetPendingCount, complete, decrementPendingCountUnlessZero, exec, firstComplete, getCompleter, getPendingCount, 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.BiFun<java.util.Map.Entry<K,V>,java.util.Map.Entry<K,V>,? extends java.util.Map.Entry<K,V>> reducer
EquivalentConcurrentHashMapV8.ReduceEntriesTask<K,V> rights
EquivalentConcurrentHashMapV8.ReduceEntriesTask<K,V> nextRight
EquivalentConcurrentHashMapV8.ReduceEntriesTask(EquivalentConcurrentHashMapV8.BulkTask<K,V,?> p, int b, int i, int f, EquivalentConcurrentHashMapV8.Node<K,V>[] t, EquivalentConcurrentHashMapV8.ReduceEntriesTask<K,V> nextRight, EquivalentConcurrentHashMapV8.BiFun<java.util.Map.Entry<K,V>,java.util.Map.Entry<K,V>,? extends java.util.Map.Entry<K,V>> reducer)
public final java.util.Map.Entry<K,V> getRawResult()
CountedCompleter
null
, which is appropriate for Void
actions, but in other cases should be overridden, almost
always to return a field or function of a field that
holds the result upon completion.getRawResult
in class CountedCompleter<java.util.Map.Entry<K,V>>
public final void compute()
CountedCompleter
compute
in class CountedCompleter<java.util.Map.Entry<K,V>>