ConcurrentLinkedQueue是Java中线程安全、非阻塞的FIFO队列，基于链表结构和CAS操作实现，支持高效并发读写，适用于高并发场景如任务调度与日志缓冲，但不支持null值，size()方法性能较差，迭代器弱一致，需注意使用限制。
在Java中，ConcurrentLinkedQueue 是一个线程安全的、无界的、基于链表结构的非阻塞队列，它使用CAS（Compare-And-Swap）操作实现高效的并发访问。由于其非阻塞特性，多个线程可以同时进行入队和出队操作而不会被阻塞，非常适合高并发场景下的数据共享。
1. ConcurrentLinkedQueue的基本特点
ConcurrentLinkedQueue 属于 java.util.concurrent 包，具有以下关键特性：
- 线程安全：内部通过原子操作保证多线程环境下的安全性。
- 非阻塞：使用CAS操作实现无锁并发控制，避免了传统同步机制带来的性能损耗。
- 先进先出（FIFO）：元素按插入顺序被处理。
- 不支持null值：添加 null 元素会抛出 NullPointerException。
- 弱一致性迭代器：遍历时不能保证反映最新的修改状态。
2. 常用方法介绍
以下是 ConcurrentLinkedQueue 提供的核心操作方法：
- offer(E e)：将元素插入队尾，成功返回 true。
- poll()：获取并移除队首元素，若队列为空则返回 null。
- peek()：查看队首元素但不移除，若为空返回 null。
- size()：返回当前队列中的元素数量（注意：此操作需要遍历链表，不适合频繁调用）。
- isEmpty()：判断队列是否为空，推荐用于空检查而非 size() == 0。
3. 实际使用示例
下面是一个多线程环境下使用 ConcurrentLinkedQueue 的简单例子：
立即学习“Java免费学习笔记（深入）”；
import java.util.concurrent.ConcurrentLinkedQueue;
public class NonBlockingQueueExample {
private static final ConcurrentLinkedQueue queue = new ConcurrentLinkedQueue<>();
public static void main(String[] args) {
// 启动两个生产者线程
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();
}
}
}).start();
// 启动一个消费者线程
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;
}
}
}
}).start();
}
}
在这个例子中，生产者不断向队列添加任务，消费者持续尝试取出任务处理。由于是非阻塞队列，消费者调用 poll() 得不到元素时直接返回 null，不会等待，因此需自行控制重试逻辑或休眠策略。
4. 使用注意事项
虽然 ConcurrentLinkedQueue 性能优秀，但在实际使用中仍需注意以下几点：
- size() 方法需要遍历整个链表，在高并发下可能不准确且性能较差，应尽量避免频繁调用。
- 不能存 null 值，否则会抛异常。
- 适用于高并发读写场景，但如果需要阻塞操作（如队列空时等待），应考虑使用 BlockingQueue 的实现类，如 LinkedBlockingQueue。
- 迭代器不保证实时一致性，适合只读遍历且对最新状态要求不高的场景。
基本上就这些。ConcurrentLinkedQueue 是实现高性能非阻塞队列的理想选择，尤其适合事件处理器、任务调度、日志缓冲等并发场景。正确理解其行为特征，能有效提升系统的吞吐能力。
