ConcurrentLinkedQueue是Java中基于CAS实现的无锁、线程安全FIFO队列，适用于高并发场景。它通过原子操作维护head和tail指针，实现高效的入队出队操作；不允许null元素，迭代器弱一致性，size()需遍历链表性能较低，且为无界队列需防内存溢出。
在Java并发编程中，ConcurrentLinkedQueue 是一个高效、线程安全的无锁队列实现。它基于链表结构，利用CAS（Compare-And-Swap）操作实现多线程环境下的非阻塞访问，适用于高并发场景下对性能要求较高的任务队列、消息传递等应用。
什么是ConcurrentLinkedQueue
ConcurrentLinkedQueue 是 java.util.concurrent 包中的一个线程安全队列，遵循 FIFO（先进先出）原则。与传统的 synchronized 队列（如 Vector 或同步包装的 LinkedList）不同，它不使用任何显式锁，而是通过原子操作和 volatile 变量保证线程安全。
主要特点包括：
- 无锁（lock-free）设计，提升高并发吞吐量
- 不允许插入 null 元素
- 迭代器弱一致性，不抛出 ConcurrentModificationException
- 适合大量并发生产者和消费者的场景
基本使用方法
创建和操作 ConcurrentLinkedQueue 非常简单，常用方法有 add()、offer()、poll()、peek() 等。
立即学习“Java免费学习笔记（深入）”；
示例代码：
import java.util.concurrent.ConcurrentLinkedQueue;
public class QueueExample {
private static final ConcurrentLinkedQueue queue = new ConcurrentLinkedQueue<>();
public static void main(String[] args) {
// 生产者线程
Thread producer = new Thread(() -> {
for (int i = 1; i <= 5; i++) {
String item = "任务-" + i;
queue.offer(item);
System.out.println("生产: " + item);
try {
Thread.sleep(100);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}
});
// 消费者线程
Thread consumer = new Thread(() -> {
while (true) {
String item = queue.poll(); // 取出并移除头元素
if (item != null) {
System.out.println("消费: " + item);
} else {
// 队列为空，稍作等待或退出
try {
Thread.sleep(200);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
break;
}
}
}
});
producer.start();
consumer.start();
}
}
在这个例子中，生产者不断向队列添加任务，消费者持续从队列取出任务处理。由于 ConcurrentLinkedQueue 的线程安全性，无需额外同步控制。
内部实现原理简析
ConcurrentLinkedQueue 使用了“无锁链表”算法，核心是两个原子引用：head 和 tail。每个节点包含数据项和指向下一个节点的指针。所有修改操作（如入队、出队）都依赖于 CAS 操作来更新指针。
关键机制包括：
- 入队（offer）：从 tail 开始寻找最后一个有效节点，通过 CAS 将新节点追加到末尾，并尝试更新 tail
- 出队（poll）：从 head 开始跳过已删除或空节点，CAS 更新头节点，确保多个线程同时 poll 不会冲突
- 延迟更新指针：head 和 tail 的移动不是实时的，仅在必要时推进，减少竞争
这种设计使得多个线程可以并行执行入队和出队操作，极大提升了并发性能。
使用注意事项
虽然 ConcurrentLinkedQueue 性能优秀，但在实际使用中仍需注意以下几点：
- size() 方法不是常量时间操作：需要遍历整个链表统计元素数量，在高并发或频繁调用时可能影响性能
- 不适合做有界队列：它是无界的，若生产速度远大于消费速度，可能导致内存溢出
- 弱一致性的迭代器：不能保证反映最新的队列状态，不适合用于精确的批量操作
- null 不允许插入：调用 offer(null) 会抛出 NullPointerException
基本上就这些。ConcurrentLinkedQueue 在高并发环境中表现优异，尤其适合做任务调度、事件队列等场景。只要理解其无锁机制和行为特性，就能安全高效地使用它。
