ConcurrentLinkedQueue 是 Java 中基于 CAS 实现的无锁、线程安全、无界 FIFO 队列;插入在队尾、删除在队头,用 volatile head/tail 保证可见性,size() 非常量时间且不准确,应优先用 isEmpty(),迭代器提供弱一致性快照。

ConcurrentLinkedQueue 是 Java 并发包(java.util.concurrent)中一个线程安全、无界、基于链表的 FIFO 队列。
它是一个无锁的非阻塞队列
不依赖 synchronized 或 ReentrantLock,而是靠 CAS(Compare-And-Swap)原子操作实现线程安全。多个线程同时 offer(入队)或 poll(出队)时,不会互相阻塞,也不会因锁竞争导致上下文切换开销。
- 插入总在队尾,删除总在队头,严格遵循先进先出
- 内部用 volatile 修饰的
head和tail指针维护链表首尾,保证内存可见性 - 节点是单向链表结构,每个 Node 包含
item(元素)和next(后继指针)
它没有容量限制,但 size() 不是常量时间
理论上可无限增长(实际受限于堆内存),offer(e) 总是返回 true,不会失败或阻塞。
-
size()需要遍历整个链表计数,且遍历时若其他线程修改队列,结果可能不准确 - 所以生产环境避免在高频路径中频繁调用
size() - 判断空用
isEmpty(),它只检查 head.item 是否为 null,更快更可靠
它提供弱一致性的迭代器
调用 iterator() 得到的迭代器,反映的是创建那一刻的队列快照,遍历时即使其他线程增删元素,也不会抛 ConcurrentModificationException,也不会漏掉或重复遍历已存在的元素。
立即学习“Java免费学习笔记(深入)”;
- 适合“读多写少”或对实时一致性要求不苛刻的场景
- 不适合需要强一致性遍历(比如做原子性批量处理)的逻辑
基本上就这些。它不是万能队列,但当你需要高吞吐、低延迟、纯内存、无锁并发的 FIFO 缓冲时,ConcurrentLinkedQueue 是非常自然的选择。











