Class ConcurrentCollections
java.lang.Object
org.elasticsearch.common.util.concurrent.ConcurrentCollections
public abstract class ConcurrentCollections
extends java.lang.Object
-
Method Summary
Modifier and Type Method Description static <T> java.util.concurrent.BlockingQueue<T>newBlockingQueue()static <K, V> java.util.concurrent.ConcurrentMap<K,V>newConcurrentMap()static <V> ConcurrentMapLong<V>newConcurrentMapLong()static <V> ConcurrentMapLong<V>newConcurrentMapLongWithAggressiveConcurrency()Creates a new CHM with an aggressive concurrency level, aimed at highly updateable long living maps.static <K, V> java.util.concurrent.ConcurrentMap<K,V>newConcurrentMapWithAggressiveConcurrency()Creates a new CHM with an aggressive concurrency level, aimed at high concurrent update rate long living maps.static <K, V> java.util.concurrent.ConcurrentMap<K,V>newConcurrentMapWithAggressiveConcurrency(int initalCapacity)Creates a new CHM with an aggressive concurrency level, aimed at high concurrent update rate long living maps.static <V> java.util.Set<V>newConcurrentSet()static <T> java.util.Deque<T>newDeque()static <T> java.util.Queue<T>newQueue()
-
Method Details
-
newConcurrentMapWithAggressiveConcurrency
public static <K, V> java.util.concurrent.ConcurrentMap<K,V> newConcurrentMapWithAggressiveConcurrency()Creates a new CHM with an aggressive concurrency level, aimed at high concurrent update rate long living maps. -
newConcurrentMapWithAggressiveConcurrency
public static <K, V> java.util.concurrent.ConcurrentMap<K,V> newConcurrentMapWithAggressiveConcurrency(int initalCapacity)Creates a new CHM with an aggressive concurrency level, aimed at high concurrent update rate long living maps. -
newConcurrentMap
public static <K, V> java.util.concurrent.ConcurrentMap<K,V> newConcurrentMap() -
newConcurrentMapLongWithAggressiveConcurrency
Creates a new CHM with an aggressive concurrency level, aimed at highly updateable long living maps. -
newConcurrentMapLong
-
newConcurrentSet
public static <V> java.util.Set<V> newConcurrentSet() -
newQueue
public static <T> java.util.Queue<T> newQueue() -
newDeque
public static <T> java.util.Deque<T> newDeque() -
newBlockingQueue
public static <T> java.util.concurrent.BlockingQueue<T> newBlockingQueue()
-