贝利信息

Java中ConcurrentSkipListSet使用方法

日期:2025-09-25 00:00 / 作者:P粉602998670
ConcurrentSkipListSet是Java中基于跳跃表实现的线程安全有序集合,支持高并发下非阻塞操作,元素按自然顺序或自定义比较器排序,不允许null值和重复元素,提供高效的增删查及范围视图功能,适用于读多写少或并发频繁的有序场景。

ConcurrentSkipListSet 是 Java 中基于跳跃表(Skip List)实现的有序、线程安全的集合。它适用于高并发环境下需要排序且不重复元素的场景,内部使用 CAS 操作保证线程安全,避免了锁的开销。

基本特点

有序性:元素按自然顺序或自定义比较器排序。
非阻塞并发:采用无锁算法(CAS),多线程操作效率较高。
不允许 null 值:插入 null 会抛出 NullPointerException。
不支持重复元素:和 Set 接口一致,自动去重。

创建与初始化

可以使用默认排序或传入自定义 Comparator。

// 默认自然排序(要求元素实现 Comparable)
ConcurrentSkipListSet set = new ConcurrentSkipListSet<>();

// 自定义排序:按字符串长度排序 ConcurrentSkipListSet set2 = new ConcurrentSkipListSet<>( (a, b) -> Integer.compare(a.length(), b.length()) );

常用方法示例

以下是增删查等常见操作的使用方式:

ConcurrentSkipListSet set = new ConcurrentSkipListSet<>();

set.add(30); // 添加元素 set.add(10); set.add(20);

System.out.println(set); // 输出: [10, 20, 30](有序)

set.remove(20); // 删除元素 System.out.println(set); // 输出: [10, 30]

boolean contains = set.contains(10); // 判断是否存在 System.out.println(contains); // true

Integer first = set.first(); // 获取最小元素 Integer last = set.last(); // 获取最大元素 System.out.println("最小: " + first + ", 最大: " + last);

获取子集与范围操作

支持根据范围获取视图,这些视图是动态的,底层数据变化会反映到视图中。

// 获取从 15 到 35 的元素(包含边界)
SortedSet subSet = set.subSet(15, 35);
System.out.println(subSet);  // 输出匹配范围的元素

// 获取小于等于 25 的部分 SortedSet headSet = set.headSet(25); // 获取大于等于 15 的部分 SortedSet tailSet =

set.tailSet(15);

线程安全使用示例

多个线程可安全地并发访问 ConcurrentSkipListSet。

ConcurrentSkipListSet set = new ConcurrentSkipListSet<>();

Runnable task = () -> { for (int i = 0; i < 1000; i++) { set.add(i); set.remove(i - 10); } };

Thread t1 = new Thread(task); Thread t2 = new Thread(task); t1.start(); t2.start();

try { t1.join(); t2.join(); } catch (InterruptedException e) { Thread.currentThread().interrupt(); }

System.out.println("最终大小: " + set.size());

基本上就这些。ConcurrentSkipListSet 在读多写少或并发插入删除较多的有序集合场景下表现良好,替代 synchronized 的 TreeSet 更高效。注意不能存 null,且元素或比较器要正确实现排序逻辑,否则运行时可能出错。