abstract static class ConcurrentHashMapV8.BulkTask<K,V,R> extends CountedCompleter<R>
ForkJoinTask.AdaptedCallable<T>, ForkJoinTask.AdaptedRunnable<T>, ForkJoinTask.AdaptedRunnableAction, ForkJoinTask.ExceptionNode, ForkJoinTask.RunnableExecuteAction
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 |
completer, pending
CANCELLED, DONE_MASK, EXCEPTIONAL, NORMAL, SIGNAL, SMASK, status
Constructor and Description |
---|
BulkTask(ConcurrentHashMapV8.BulkTask<K,V,?> par,
int b,
int i,
int f,
ConcurrentHashMapV8.Node<K,V>[] t) |
Modifier and Type | Method and Description |
---|---|
(package private) ConcurrentHashMapV8.Node<K,V> |
advance()
Same as Traverser version
|
addToPendingCount, compareAndSetPendingCount, complete, compute, 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
ConcurrentHashMapV8.Node<K,V>[] tab
ConcurrentHashMapV8.Node<K,V> next
int index
int baseIndex
int baseLimit
final int baseSize
int batch
BulkTask(ConcurrentHashMapV8.BulkTask<K,V,?> par, int b, int i, int f, ConcurrentHashMapV8.Node<K,V>[] t)
final ConcurrentHashMapV8.Node<K,V> advance()