Package org.elasticsearch.common.util.concurrent

Class ConcurrentCollections

java.lang.Object

org.elasticsearch.common.util.concurrent.ConcurrentCollections

public abstract class ConcurrentCollections
extends Object

Method Summary

Modifier and Type	Method	Description
static <T> BlockingQueue<T>	newBlockingQueue()
static <K, V> 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> 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> 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> Set<V>	newConcurrentSet()
static <T> Deque<T>	newDeque()
static <T> Queue<T>	newQueue()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

newConcurrentMapWithAggressiveConcurrency

public static <K,
V> 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> 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> ConcurrentMap<K,V> newConcurrentMap()

newConcurrentMapLongWithAggressiveConcurrency

public static <V> ConcurrentMapLong<V> newConcurrentMapLongWithAggressiveConcurrency()

Creates a new CHM with an aggressive concurrency level, aimed at highly updateable long living maps.

newConcurrentMapLong

public static <V> ConcurrentMapLong<V> newConcurrentMapLong()

newConcurrentSet

public static <V> Set<V> newConcurrentSet()

newQueue

public static <T> Queue<T> newQueue()

newDeque

public static <T> Deque<T> newDeque()

newBlockingQueue

public static <T> BlockingQueue<T> newBlockingQueue()