ConcurrentLinkedDeque 是基于 CAS 无锁算法实现的线程安全双端队列,适用于高并发低争用场景;支持两端高效增删、弱一致性迭代器、非实时 size(),不允 null 元素,适合工作窃取、日志缓冲等最终一致性场景。
Java 中 ConcurrentLinkedDeque 是一个基于无锁(lock-free)算法实现的线程安全双端队列,适用于高并发、低争用场景。它不使用 synchronized 或 ReentrantLock,而是依赖 CAS(Compare-and-Swap)操作保证原子性,因此吞吐量高、扩展性好,但不保证强一致性,也不支持阻塞操作。
直接 new 即可,无需指定容量(底层是链表结构,动态扩容):
ConcurrentLinkedDeque
支持从两端高效添加/删除元素:
所有 public 方法都是线程安全的,内部通过原子更新 head/tail 节点 + 多次 CAS 重试实现。注意几个关键点:
适合读多写少、对延迟敏感、能接受最终一致性的场景,例如:
若需要阻塞能力(如 take() 等待非空)、精确 size 控制或更强顺序保证,应考虑 LinkedBlockingDeque(基于锁 + 条件队列)或 ArrayBlockingQueue(有界、可重入锁)。
比如多个线程向队列两端写入,主线程消费:
// 生产者线程 A(加到头部)
new Thread(() -> {
for (int i = 0; i deque.offerFirst("A-" + i);
}
}).start();
// 生产者线程 B(加到尾部)
new Thread(() -> {
for (int i = 0; i deque.offerLast("B-" + i);
}
}).start();
// 消费者(按 FIFO 顺序取)
while (!deque.isEmpty()) {
String s = deque.poll(); //
if (s != null) System.out.println(s);
}
注意:由于无锁和并发修改,实际输出顺序不严格确定,但每个元素只被消费一次,不会丢失或重复。
基本上就这些。ConcurrentLinkedDeque 的设计目标是高性能而非强语义,用对场景才能发挥优势。