ConcurrentCollections (opensearch-common 2.11.1 API)

java.lang.Object

org.opensearch.common.util.concurrent.ConcurrentCollections

public abstract class ConcurrentCollections extends Object

Thread safe collection base class.

Opensearch.internal:

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