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()
-