org.infinispan.commons.util.concurrent.jdk8backported

Class EquivalentConcurrentHashMapV8.BulkTask<K,V,R>

java.lang.Object

org.infinispan.commons.util.concurrent.jdk8backported.ForkJoinTask<T>

org.infinispan.commons.util.concurrent.jdk8backported.CountedCompleter<R>

org.infinispan.commons.util.concurrent.jdk8backported.EquivalentConcurrentHashMapV8.BulkTask<K,V,R>

All Implemented Interfaces:

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

Direct Known Subclasses:

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

Enclosing class:

EquivalentConcurrentHashMapV8<K,V>

abstract static class EquivalentConcurrentHashMapV8.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 org.infinispan.commons.util.concurrent.jdk8backported.ForkJoinTask

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

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) EquivalentConcurrentHashMapV8.Node<K,V>	next
(package private) EquivalentConcurrentHashMapV8.Node<K,V>[]	tab

Fields inherited from class org.infinispan.commons.util.concurrent.jdk8backported.CountedCompleter

completer, pending

Fields inherited from class org.infinispan.commons.util.concurrent.jdk8backported.ForkJoinTask

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

Constructor Summary

Constructors

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

Method Summary

Methods

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

Methods inherited from class org.infinispan.commons.util.concurrent.jdk8backported.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 org.infinispan.commons.util.concurrent.jdk8backported.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

EquivalentConcurrentHashMapV8.Node<K,V>[] tab

next

EquivalentConcurrentHashMapV8.Node<K,V> next

index

int index

baseIndex

int baseIndex

baseLimit

int baseLimit

baseSize

final int baseSize

batch

int batch

Constructor Detail

EquivalentConcurrentHashMapV8.BulkTask

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

Method Detail

advance

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

Same as Traverser version