java.lang.Object

cloud.opencode.base.collections.concurrent.ConcurrentCollectionFactory

public final class ConcurrentCollectionFactory extends Object

ConcurrentCollectionFactory - Factory for Thread-safe Collections ConcurrentCollectionFactory - 线程安全集合工厂

Provides factory methods for creating various thread-safe collections.

提供创建各种线程安全集合的工厂方法。

Features | 主要功能:

Thread-safe collection creation - 线程安全集合创建
Various concurrency levels - 各种并发级别
Optimized implementations - 优化的实现

Usage Examples | 使用示例:

// Create concurrent map - 创建并发映射
Map<String, Integer> map = ConcurrentCollectionFactory.newConcurrentMap();

// Create concurrent set - 创建并发集合
Set<String> set = ConcurrentCollectionFactory.newConcurrentSet();

// Create blocking queue - 创建阻塞队列
Queue<String> queue = ConcurrentCollectionFactory.newBlockingQueue(100);

Since:

JDK 25, opencode-base-collections V1.0.0

Author:

Leon Soo www.LeonSoo.com

See Also:

Method Summary

Modifier and Type

Method

Description

static <E> BlockingDeque<E>

newBlockingDeque()

Create a new LinkedBlockingDeque.

static <E> BlockingDeque<E>

newBlockingDeque(int capacity)

Create a new LinkedBlockingDeque with capacity.

static <E> BlockingQueue<E>

newBlockingQueue(int capacity)

Create a new ArrayBlockingQueue.

static <E> Deque<E>

newConcurrentDeque()

Create a new ConcurrentLinkedDeque.

static <K,V> ConcurrentMap<K,V>

newConcurrentMap()

Create a new ConcurrentHashMap.

static <K,V> ConcurrentMap<K,V>

newConcurrentMap(int initialCapacity)

Create a new ConcurrentHashMap with initial capacity.

static <E> Queue<E>

newConcurrentQueue()

Create a new ConcurrentLinkedQueue.

static <E> Set<E>

newConcurrentSet()

Create a new concurrent set backed by ConcurrentHashMap.

static <E> Set<E>

newConcurrentSet(int initialCapacity)

Create a new concurrent set with initial capacity.

static <K,V> ConcurrentNavigableMap<K,V>

newConcurrentSortedMap()

Create a new ConcurrentSkipListMap.

static <K,V> ConcurrentNavigableMap<K,V>

newConcurrentSortedMap(Comparator<? super K> comparator)

Create a new ConcurrentSkipListMap with comparator.

static <E> NavigableSet<E>

newConcurrentSortedSet()

Create a new ConcurrentSkipListSet.

static <E> NavigableSet<E>

newConcurrentSortedSet(Comparator<? super E> comparator)

Create a new ConcurrentSkipListSet with comparator.

static <E> List<E>

newCopyOnWriteList()

Create a new CopyOnWriteArrayList.

static <E> List<E>

newCopyOnWriteList(Collection<? extends E> collection)

Create a new CopyOnWriteArrayList from collection.

static <E> Set<E>

newCopyOnWriteSet()

Create a new CopyOnWriteArraySet.

static <E extends Delayed> BlockingQueue<E>

newDelayQueue()

Create a new DelayQueue.

static <E> BlockingQueue<E>

newLinkedBlockingQueue()

Create a new LinkedBlockingQueue.

static <E> BlockingQueue<E>

newLinkedBlockingQueue(int capacity)

Create a new LinkedBlockingQueue with capacity.

static <E> LockFreeStack<E>

newLockFreeStack()

Creates a new lock-free concurrent stack.

static <E> BlockingQueue<E>

newPriorityBlockingQueue()

Create a new PriorityBlockingQueue.

static <E> BlockingQueue<E>

newSynchronousQueue()

Create a new SynchronousQueue.

static <E> List<E>

synchronizedList(List<E> list)

Create a synchronized list from any list.

static <K,V> Map<K,V>

synchronizedMap(Map<K,V> map)

Create a synchronized map from any map.

static <E> Set<E>

synchronizedSet(Set<E> set)

Create a synchronized set from any set.

Methods inherited from class Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details
- newConcurrentMap
  
  public static <K,V> ConcurrentMap<K,V> newConcurrentMap()
  
  Create a new ConcurrentHashMap. 创建新 ConcurrentHashMap。
  
  Type Parameters:
  
  K - key type | 键类型
  
  V - value type | 值类型
  
  Returns:
  
  new ConcurrentHashMap | 新 ConcurrentHashMap
- newConcurrentMap
  
  public static <K,V> ConcurrentMap<K,V> newConcurrentMap(int initialCapacity)
  
  Create a new ConcurrentHashMap with initial capacity. 创建指定初始容量的新 ConcurrentHashMap。
  
  Type Parameters:
  
  K - key type | 键类型
  
  V - value type | 值类型
  
  Parameters:
  
  initialCapacity - initial capacity | 初始容量
  
  Returns:
  
  new ConcurrentHashMap | 新 ConcurrentHashMap
- newConcurrentSortedMap
  
  public static <K,V> ConcurrentNavigableMap<K,V> newConcurrentSortedMap()
  
  Create a new ConcurrentSkipListMap. 创建新 ConcurrentSkipListMap。
  
  Type Parameters:
  
  K - key type | 键类型
  
  V - value type | 值类型
  
  Returns:
  
  new ConcurrentSkipListMap | 新 ConcurrentSkipListMap
- newConcurrentSortedMap
  
  public static <K,V> ConcurrentNavigableMap<K,V> newConcurrentSortedMap(Comparator<? super K> comparator)
  
  Create a new ConcurrentSkipListMap with comparator. 创建具有比较器的新 ConcurrentSkipListMap。
  
  Type Parameters:
  
  K - key type | 键类型
  
  V - value type | 值类型
  
  Parameters:
  
  comparator - the comparator | 比较器
  
  Returns:
  
  new ConcurrentSkipListMap | 新 ConcurrentSkipListMap
- newConcurrentSet
  
  public static <E> Set<E> newConcurrentSet()
  
  Create a new concurrent set backed by ConcurrentHashMap. 创建由 ConcurrentHashMap 支持的新并发集合。
  
  Type Parameters:
  
  E - element type | 元素类型
  
  Returns:
  
  new concurrent set | 新并发集合
- newConcurrentSet
  
  public static <E> Set<E> newConcurrentSet(int initialCapacity)
  
  Create a new concurrent set with initial capacity. 创建指定初始容量的新并发集合。
  
  Type Parameters:
  
  E - element type | 元素类型
  
  Parameters:
  
  initialCapacity - initial capacity | 初始容量
  
  Returns:
  
  new concurrent set | 新并发集合
- newConcurrentSortedSet
  
  public static <E> NavigableSet<E> newConcurrentSortedSet()
  
  Create a new ConcurrentSkipListSet. 创建新 ConcurrentSkipListSet。
  
  Type Parameters:
  
  E - element type | 元素类型
  
  Returns:
  
  new ConcurrentSkipListSet | 新 ConcurrentSkipListSet
- newConcurrentSortedSet
  
  public static <E> NavigableSet<E> newConcurrentSortedSet(Comparator<? super E> comparator)
  
  Create a new ConcurrentSkipListSet with comparator. 创建具有比较器的新 ConcurrentSkipListSet。
  
  Type Parameters:
  
  E - element type | 元素类型
  
  Parameters:
  
  comparator - the comparator | 比较器
  
  Returns:
  
  new ConcurrentSkipListSet | 新 ConcurrentSkipListSet
- newConcurrentQueue
  
  public static <E> Queue<E> newConcurrentQueue()
  
  Create a new ConcurrentLinkedQueue. 创建新 ConcurrentLinkedQueue。
  
  Type Parameters:
  
  E - element type | 元素类型
  
  Returns:
  
  new ConcurrentLinkedQueue | 新 ConcurrentLinkedQueue
- newConcurrentDeque
  
  public static <E> Deque<E> newConcurrentDeque()
  
  Create a new ConcurrentLinkedDeque. 创建新 ConcurrentLinkedDeque。
  
  Type Parameters:
  
  E - element type | 元素类型
  
  Returns:
  
  new ConcurrentLinkedDeque | 新 ConcurrentLinkedDeque
- newBlockingQueue
  
  public static <E> BlockingQueue<E> newBlockingQueue(int capacity)
  
  Create a new ArrayBlockingQueue. 创建新 ArrayBlockingQueue。
  
  Type Parameters:
  
  E - element type | 元素类型
  
  Parameters:
  
  capacity - the capacity | 容量
  
  Returns:
  
  new ArrayBlockingQueue | 新 ArrayBlockingQueue
- newLinkedBlockingQueue
  
  public static <E> BlockingQueue<E> newLinkedBlockingQueue()
  
  Create a new LinkedBlockingQueue. 创建新 LinkedBlockingQueue。
  
  Type Parameters:
  
  E - element type | 元素类型
  
  Returns:
  
  new LinkedBlockingQueue | 新 LinkedBlockingQueue
- newLinkedBlockingQueue
  
  public static <E> BlockingQueue<E> newLinkedBlockingQueue(int capacity)
  
  Create a new LinkedBlockingQueue with capacity. 创建指定容量的新 LinkedBlockingQueue。
  
  Type Parameters:
  
  E - element type | 元素类型
  
  Parameters:
  
  capacity - the capacity | 容量
  
  Returns:
  
  new LinkedBlockingQueue | 新 LinkedBlockingQueue
- newPriorityBlockingQueue
  
  public static <E> BlockingQueue<E> newPriorityBlockingQueue()
  
  Create a new PriorityBlockingQueue. 创建新 PriorityBlockingQueue。
  
  Type Parameters:
  
  E - element type | 元素类型
  
  Returns:
  
  new PriorityBlockingQueue | 新 PriorityBlockingQueue
- newDelayQueue
  
  public static <E extends Delayed> BlockingQueue<E> newDelayQueue()
  
  Create a new DelayQueue. 创建新 DelayQueue。
  
  Type Parameters:
  
  E - element type | 元素类型
  
  Returns:
  
  new DelayQueue | 新 DelayQueue
- newSynchronousQueue
  
  public static <E> BlockingQueue<E> newSynchronousQueue()
  
  Create a new SynchronousQueue. 创建新 SynchronousQueue。
  
  Type Parameters:
  
  E - element type | 元素类型
  
  Returns:
  
  new SynchronousQueue | 新 SynchronousQueue
- newBlockingDeque
  
  public static <E> BlockingDeque<E> newBlockingDeque()
  
  Create a new LinkedBlockingDeque. 创建新 LinkedBlockingDeque。
  
  Type Parameters:
  
  E - element type | 元素类型
  
  Returns:
  
  new LinkedBlockingDeque | 新 LinkedBlockingDeque
- newBlockingDeque
  
  public static <E> BlockingDeque<E> newBlockingDeque(int capacity)
  
  Create a new LinkedBlockingDeque with capacity. 创建指定容量的新 LinkedBlockingDeque。
  
  Type Parameters:
  
  E - element type | 元素类型
  
  Parameters:
  
  capacity - the capacity | 容量
  
  Returns:
  
  new LinkedBlockingDeque | 新 LinkedBlockingDeque
- newLockFreeStack
  
  public static <E> LockFreeStack<E> newLockFreeStack()
  
  Creates a new lock-free concurrent stack. 创建新的无锁并发栈。
  
  Type Parameters:
  
  E - element type | 元素类型
  
  Returns:
  
  new LockFreeStack | 新 LockFreeStack
- newCopyOnWriteList
  
  public static <E> List<E> newCopyOnWriteList()
  
  Create a new CopyOnWriteArrayList. 创建新 CopyOnWriteArrayList。
  
  Type Parameters:
  
  E - element type | 元素类型
  
  Returns:
  
  new CopyOnWriteArrayList | 新 CopyOnWriteArrayList
- newCopyOnWriteList
  
  public static <E> List<E> newCopyOnWriteList(Collection<? extends E> collection)
  
  Create a new CopyOnWriteArrayList from collection. 从集合创建新 CopyOnWriteArrayList。
  
  Type Parameters:
  
  E - element type | 元素类型
  
  Parameters:
  
  collection - the collection | 集合
  
  Returns:
  
  new CopyOnWriteArrayList | 新 CopyOnWriteArrayList
- newCopyOnWriteSet
  
  public static <E> Set<E> newCopyOnWriteSet()
  
  Create a new CopyOnWriteArraySet. 创建新 CopyOnWriteArraySet。
  
  Type Parameters:
  
  E - element type | 元素类型
  
  Returns:
  
  new CopyOnWriteArraySet | 新 CopyOnWriteArraySet
- synchronizedMap
  
  public static <K,V> Map<K,V> synchronizedMap(Map<K,V> map)
  
  Create a synchronized map from any map. 从任何映射创建同步映射。
  
  Type Parameters:
  
  K - key type | 键类型
  
  V - value type | 值类型
  
  Parameters:
  
  map - the map | 映射
  
  Returns:
  
  synchronized map | 同步映射
- synchronizedSet
  
  public static <E> Set<E> synchronizedSet(Set<E> set)
  
  Create a synchronized set from any set. 从任何集合创建同步集合。
  
  Type Parameters:
  
  E - element type | 元素类型
  
  Parameters:
  
  set - the set | 集合
  
  Returns:
  
  synchronized set | 同步集合
- synchronizedList
  
  public static <E> List<E> synchronizedList(List<E> list)
  
  Create a synchronized list from any list. 从任何列表创建同步列表。
  
  Type Parameters:
  
  E - element type | 元素类型
  
  Parameters:
  
  list - the list | 列表
  
  Returns:
  
  synchronized list | 同步列表

Class ConcurrentCollectionFactory

Method Summary

Methods inherited from class Object

Method Details

newConcurrentMap

newConcurrentMap

newConcurrentSortedMap

newConcurrentSortedMap

newConcurrentSet

newConcurrentSet

newConcurrentSortedSet

newConcurrentSortedSet

newConcurrentQueue

newConcurrentDeque

newBlockingQueue

newLinkedBlockingQueue

newLinkedBlockingQueue

newPriorityBlockingQueue

newDelayQueue

newSynchronousQueue

newBlockingDeque

newBlockingDeque

newLockFreeStack

newCopyOnWriteList

newCopyOnWriteList

newCopyOnWriteSet

synchronizedMap

synchronizedSet

synchronizedList