public class ConcurrentParallelHashMapV8<K,V> extends EquivalentConcurrentHashMapV8<K,V> implements ParallelIterableMap<K,V>
EquivalentConcurrentHashMapV8.Action<A>, EquivalentConcurrentHashMapV8.BaseIterator<K,V>, EquivalentConcurrentHashMapV8.BiAction<A,B>, EquivalentConcurrentHashMapV8.BiFun<A,B,T>, EquivalentConcurrentHashMapV8.BulkTask<K,V,R>, EquivalentConcurrentHashMapV8.CollectionView<K,V,E>, EquivalentConcurrentHashMapV8.ConcurrentHashMapSpliterator<T>, EquivalentConcurrentHashMapV8.CounterCell, EquivalentConcurrentHashMapV8.CounterHashCode, EquivalentConcurrentHashMapV8.DoubleByDoubleToDouble, EquivalentConcurrentHashMapV8.EntryIterator<K,V>, EquivalentConcurrentHashMapV8.EntrySetView<K,V>, EquivalentConcurrentHashMapV8.EntrySpliterator<K,V>, EquivalentConcurrentHashMapV8.ForEachEntryTask<K,V>, EquivalentConcurrentHashMapV8.ForEachKeyTask<K,V>, EquivalentConcurrentHashMapV8.ForEachMappingTask<K,V>, EquivalentConcurrentHashMapV8.ForEachTransformedEntryTask<K,V,U>, EquivalentConcurrentHashMapV8.ForEachTransformedKeyTask<K,V,U>, EquivalentConcurrentHashMapV8.ForEachTransformedMappingTask<K,V,U>, EquivalentConcurrentHashMapV8.ForEachTransformedValueTask<K,V,U>, EquivalentConcurrentHashMapV8.ForEachValueTask<K,V>, EquivalentConcurrentHashMapV8.ForwardingNode<K,V>, EquivalentConcurrentHashMapV8.Fun<A,T>, EquivalentConcurrentHashMapV8.IntByIntToInt, EquivalentConcurrentHashMapV8.KeyIterator<K,V>, EquivalentConcurrentHashMapV8.KeySetView<K,V>, EquivalentConcurrentHashMapV8.KeySpliterator<K,V>, EquivalentConcurrentHashMapV8.LongByLongToLong, EquivalentConcurrentHashMapV8.MapEntry<K,V>, EquivalentConcurrentHashMapV8.MapReduceEntriesTask<K,V,U>, EquivalentConcurrentHashMapV8.MapReduceEntriesToDoubleTask<K,V>, EquivalentConcurrentHashMapV8.MapReduceEntriesToIntTask<K,V>, EquivalentConcurrentHashMapV8.MapReduceEntriesToLongTask<K,V>, EquivalentConcurrentHashMapV8.MapReduceKeysTask<K,V,U>, EquivalentConcurrentHashMapV8.MapReduceKeysToDoubleTask<K,V>, EquivalentConcurrentHashMapV8.MapReduceKeysToIntTask<K,V>, EquivalentConcurrentHashMapV8.MapReduceKeysToLongTask<K,V>, EquivalentConcurrentHashMapV8.MapReduceMappingsTask<K,V,U>, EquivalentConcurrentHashMapV8.MapReduceMappingsToDoubleTask<K,V>, EquivalentConcurrentHashMapV8.MapReduceMappingsToIntTask<K,V>, EquivalentConcurrentHashMapV8.MapReduceMappingsToLongTask<K,V>, EquivalentConcurrentHashMapV8.MapReduceValuesTask<K,V,U>, EquivalentConcurrentHashMapV8.MapReduceValuesToDoubleTask<K,V>, EquivalentConcurrentHashMapV8.MapReduceValuesToIntTask<K,V>, EquivalentConcurrentHashMapV8.MapReduceValuesToLongTask<K,V>, EquivalentConcurrentHashMapV8.Node<K,V>, EquivalentConcurrentHashMapV8.NodeEquivalence<K,V>, EquivalentConcurrentHashMapV8.ObjectByObjectToDouble<A,B>, EquivalentConcurrentHashMapV8.ObjectByObjectToInt<A,B>, EquivalentConcurrentHashMapV8.ObjectByObjectToLong<A,B>, EquivalentConcurrentHashMapV8.ObjectToDouble<A>, EquivalentConcurrentHashMapV8.ObjectToInt<A>, EquivalentConcurrentHashMapV8.ObjectToLong<A>, EquivalentConcurrentHashMapV8.ReduceEntriesTask<K,V>, EquivalentConcurrentHashMapV8.ReduceKeysTask<K,V>, EquivalentConcurrentHashMapV8.ReduceValuesTask<K,V>, EquivalentConcurrentHashMapV8.ReservationNode<K,V>, EquivalentConcurrentHashMapV8.SearchEntriesTask<K,V,U>, EquivalentConcurrentHashMapV8.SearchKeysTask<K,V,U>, EquivalentConcurrentHashMapV8.SearchMappingsTask<K,V,U>, EquivalentConcurrentHashMapV8.SearchValuesTask<K,V,U>, EquivalentConcurrentHashMapV8.Segment<K,V>, EquivalentConcurrentHashMapV8.TableStack<K,V>, EquivalentConcurrentHashMapV8.Traverser<K,V>, EquivalentConcurrentHashMapV8.TreeBin<K,V>, EquivalentConcurrentHashMapV8.TreeNode<K,V>, EquivalentConcurrentHashMapV8.ValueIterator<K,V>, EquivalentConcurrentHashMapV8.ValueSpliterator<K,V>, EquivalentConcurrentHashMapV8.ValuesView<K,V>
java.util.AbstractMap.SimpleEntry<K,V>, java.util.AbstractMap.SimpleImmutableEntry<K,V>
ParallelIterableMap.KeyValueAction<A,B>
Modifier and Type | Field and Description |
---|---|
private static long |
serialVersionUID |
counterHashCodeGenerator, HASH_BITS, keyEq, MAX_ARRAY_SIZE, MIN_TREEIFY_CAPACITY, MOVED, NCPU, nodeEq, RESERVED, SEED_INCREMENT, table, threadCounterHashCode, TREEBIN, TREEIFY_THRESHOLD, UNTREEIFY_THRESHOLD, valueEq
Constructor and Description |
---|
ConcurrentParallelHashMapV8(Equivalence<K> keyEquivalence,
Equivalence<V> valueEquivalence) |
ConcurrentParallelHashMapV8(int initialCapacity,
Equivalence<K> keyEquivalence,
Equivalence<V> valueEquivalence) |
ConcurrentParallelHashMapV8(int initialCapacity,
float loadFactor,
Equivalence<K> keyEquivalence,
Equivalence<V> valueEquivalence) |
ConcurrentParallelHashMapV8(int initialCapacity,
float loadFactor,
int concurrencyLevel,
Equivalence<K> keyEquivalence,
Equivalence<V> valueEquivalence) |
ConcurrentParallelHashMapV8(java.util.Map<? extends K,? extends V> m,
Equivalence<K> keyEquivalence,
Equivalence<V> valueEquivalence) |
Modifier and Type | Method and Description |
---|---|
void |
forEach(long parallelismThreshold,
ParallelIterableMap.KeyValueAction<? super K,? super V> action)
Performs the given action for each (key, value) but traversing entries in parallel.
|
batchFor, casTabAt, clear, comparableClassFor, compareComparables, compute, computeIfAbsent, computeIfPresent, contains, containsKey, containsValue, elements, entrySet, equals, forEach, forEach, forEach, forEachEntry, forEachEntry, forEachKey, forEachKey, forEachValue, forEachValue, get, getOrDefault, hashCode, helpTransfer, isEmpty, keys, keySet, keySet, mappingCount, merge, newKeySet, newKeySet, put, putAll, putIfAbsent, putVal, reduce, reduceEntries, reduceEntries, reduceEntriesToDouble, reduceEntriesToInt, reduceEntriesToLong, reduceKeys, reduceKeys, reduceKeysToDouble, reduceKeysToInt, reduceKeysToLong, reduceToDouble, reduceToInt, reduceToLong, reduceValues, reduceValues, reduceValuesToDouble, reduceValuesToInt, reduceValuesToLong, remove, remove, replace, replace, replaceAll, replaceNode, resizeStamp, search, searchEntries, searchKeys, searchValues, setTabAt, size, spread, sumCount, tabAt, toString, untreeify, values
private static final long serialVersionUID
public ConcurrentParallelHashMapV8(Equivalence<K> keyEquivalence, Equivalence<V> valueEquivalence)
public ConcurrentParallelHashMapV8(int initialCapacity, Equivalence<K> keyEquivalence, Equivalence<V> valueEquivalence)
public ConcurrentParallelHashMapV8(int initialCapacity, float loadFactor, Equivalence<K> keyEquivalence, Equivalence<V> valueEquivalence)
public ConcurrentParallelHashMapV8(int initialCapacity, float loadFactor, int concurrencyLevel, Equivalence<K> keyEquivalence, Equivalence<V> valueEquivalence)
public ConcurrentParallelHashMapV8(java.util.Map<? extends K,? extends V> m, Equivalence<K> keyEquivalence, Equivalence<V> valueEquivalence)
public void forEach(long parallelismThreshold, ParallelIterableMap.KeyValueAction<? super K,? super V> action) throws java.lang.InterruptedException
ParallelIterableMap
forEach
in interface ParallelIterableMap<K,V>
parallelismThreshold
- the (estimated) number of elements
needed for this operation to be executed in parallelaction
- the actionjava.lang.InterruptedException