io.netty.util.internal.chmv8

Class ConcurrentHashMapV8.BulkTask<K,V,R>

java.lang.Object

io.netty.util.internal.chmv8.ForkJoinTask<T>

io.netty.util.internal.chmv8.CountedCompleter<R>

io.netty.util.internal.chmv8.ConcurrentHashMapV8.BulkTask<K,V,R>

All Implemented Interfaces:

java.io.Serializable, java.util.concurrent.Future<R>

Direct Known Subclasses:

ConcurrentHashMapV8.ForEachEntryTask, ConcurrentHashMapV8.ForEachKeyTask, ConcurrentHashMapV8.ForEachMappingTask, ConcurrentHashMapV8.ForEachTransformedEntryTask, ConcurrentHashMapV8.ForEachTransformedKeyTask, ConcurrentHashMapV8.ForEachTransformedMappingTask, ConcurrentHashMapV8.ForEachTransformedValueTask, ConcurrentHashMapV8.ForEachValueTask, ConcurrentHashMapV8.MapReduceEntriesTask, ConcurrentHashMapV8.MapReduceEntriesToDoubleTask, ConcurrentHashMapV8.MapReduceEntriesToIntTask, ConcurrentHashMapV8.MapReduceEntriesToLongTask, ConcurrentHashMapV8.MapReduceKeysTask, ConcurrentHashMapV8.MapReduceKeysToDoubleTask, ConcurrentHashMapV8.MapReduceKeysToIntTask, ConcurrentHashMapV8.MapReduceKeysToLongTask, ConcurrentHashMapV8.MapReduceMappingsTask, ConcurrentHashMapV8.MapReduceMappingsToDoubleTask, ConcurrentHashMapV8.MapReduceMappingsToIntTask, ConcurrentHashMapV8.MapReduceMappingsToLongTask, ConcurrentHashMapV8.MapReduceValuesTask, ConcurrentHashMapV8.MapReduceValuesToDoubleTask, ConcurrentHashMapV8.MapReduceValuesToIntTask, ConcurrentHashMapV8.MapReduceValuesToLongTask, ConcurrentHashMapV8.ReduceEntriesTask, ConcurrentHashMapV8.ReduceKeysTask, ConcurrentHashMapV8.ReduceValuesTask, ConcurrentHashMapV8.SearchEntriesTask, ConcurrentHashMapV8.SearchKeysTask, ConcurrentHashMapV8.SearchMappingsTask, ConcurrentHashMapV8.SearchValuesTask

Enclosing class:

ConcurrentHashMapV8<K,V>

abstract static class ConcurrentHashMapV8.BulkTask<K,V,R>
extends CountedCompleter<R>

Base class for bulk tasks. Repeats some fields and code from class Traverser, because we need to subclass CountedCompleter.

Nested Class Summary

Nested classes/interfaces inherited from class io.netty.util.internal.chmv8.ForkJoinTask

ForkJoinTask.AdaptedCallable<T>, ForkJoinTask.AdaptedRunnable<T>, ForkJoinTask.AdaptedRunnableAction, ForkJoinTask.ExceptionNode, ForkJoinTask.RunnableExecuteAction

Field Summary

Fields

Modifier and Type	Field and Description
(package private) int	baseIndex
(package private) int	baseLimit
(package private) int	baseSize
(package private) int	batch
(package private) int	index
(package private) ConcurrentHashMapV8.Node<K,V>	next
(package private) ConcurrentHashMapV8.Node<K,V>[]	tab

Fields inherited from class io.netty.util.internal.chmv8.CountedCompleter

completer, pending

Fields inherited from class io.netty.util.internal.chmv8.ForkJoinTask

CANCELLED, DONE_MASK, EXCEPTIONAL, NORMAL, SIGNAL, SMASK, status

Constructor Summary

Constructors

Constructor and Description
BulkTask(ConcurrentHashMapV8.BulkTask<K,V,?> par, int b, int i, int f, ConcurrentHashMapV8.Node<K,V>[] t)

Method Summary

Modifier and Type	Method and Description
(package private) ConcurrentHashMapV8.Node<K,V>	advance() Same as Traverser version

Methods inherited from class io.netty.util.internal.chmv8.CountedCompleter

addToPendingCount, compareAndSetPendingCount, complete, compute, decrementPendingCountUnlessZero, exec, firstComplete, getCompleter, getPendingCount, getRawResult, getRoot, internalPropagateException, nextComplete, onCompletion, onExceptionalCompletion, propagateCompletion, quietlyCompleteRoot, setPendingCount, setRawResult, tryComplete

Methods inherited from class io.netty.util.internal.chmv8.ForkJoinTask

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

Methods inherited from class java.lang.Object

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

Field Detail

tab

ConcurrentHashMapV8.Node<K,V>[] tab

next

ConcurrentHashMapV8.Node<K,V> next

index

int index

baseIndex

int baseIndex

baseLimit

int baseLimit

baseSize

final int baseSize

batch

int batch

Constructor Detail

BulkTask

BulkTask(ConcurrentHashMapV8.BulkTask<K,V,?> par,
         int b,
         int i,
         int f,
         ConcurrentHashMapV8.Node<K,V>[] t)

Method Detail

advance

final ConcurrentHashMapV8.Node<K,V> advance()

Same as Traverser version