ConcurrentLinkedQueue是Java中基于CAS实现的无锁、线程安全队列，适用于高并发非阻塞场景；它遵循FIFO原则，支持高效add和poll操作，但不支持阻塞等待和null元素插入；size()方法在并发下可能不精确，需避免用于精确判断，且使用时应妥善处理poll返回null的情况；相比BlockingQueue等，更适合对响应性要求高、无需阻塞的异步任务处理。
在多线程编程中，线程安全的队列是实现生产者-消费者模型、任务调度等场景的重要工具。Java 提供了多种线程安全的队列实现，其中 ConcurrentLinkedQueue 是一个高效、无锁（lock-free）的线程安全队列，基于链表结构实现，适用于高并发环境下的非阻塞操作。
ConcurrentLinkedQueue 简介
ConcurrentLinkedQueue 是 Java.util.concurrent 包中的一个线程安全队列，它使用 CAS（Compare-and-Swap）操作实现无锁并发控制，因此在高并发下性能表现优异。它实现了 Queue 接口，遵循 FIFO（先进先出）原则，但不支持阻塞操作（如 take() 或 put()），也不支持 null 元素插入。
主要特点：
- 线程安全：内部通过原子操作保证多线程访问安全
- 无锁设计：使用 CAS 避免传统锁带来的性能开销
- 非阻塞：add() 和 poll() 操作不会阻塞线程
- 不支持阻塞等待：如果队列为空，poll() 返回 null，而不是等待
基本用法示例
下面是一个简单的 ConcurrentLinkedQueue 使用示例，模拟多个线程向队列添加任务，另一个线程消费任务。
import java.util.concurrent.ConcurrentLinkedQueue;
public class TaskQueueExample {
// 创建一个线程安全的队列
private static final ConcurrentLinkedQueue taskQueue =
new ConcurrentLinkedQueue<>();
public static void main(String[] args) {
// 启动消费者线程
Thread consumer
= new Thread(() -> {
while (true) {
String task = taskQueue.poll(); // 取出任务，若为空返回null
if (task != null) {
System.out.println("处理任务: " + task);
} else {
// 队列为空时短暂休眠，避免空转
try {
Thread.sleep(100);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
break;
}
}
}
});
consumer.setDaemon(true); // 设为守护线程
consumer.start();
// 启动多个生产者线程
for (int i = 1; i <= 3; i++) {
final int threadId = i;
new Thread(() -> {
for (int j = 1; j <= 3; j++) {
String task = "来自线程-" + threadId + " 的任务-" + j;
taskQueue.add(task);
System.out.println("提交任务: " + task);
try {
Thread.sleep(50); // 模拟任务生成间隔
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}
}).start();
}
// 主线程等待一段时间后退出
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
System.out.println("程序结束");
}
}
适用场景与注意事项
适用场景：
- 高并发环境下需要频繁入队出队操作
- 对响应性要求高，不能接受锁竞争导致的阻塞
- 可以容忍 poll 返回 null 并自行处理空状态
注意事项：
- size() 方法在并发环境下可能不精确，因为它遍历链表计数，期间元素可能被修改
- 不允许插入 null 值，否则会抛出 NullPointerException
- 虽然线程安全，但复合操作（如检查后删除）仍需注意逻辑一致性
与其他线程安全队列对比
Java 中还有其他线程安全队列，选择时需根据需求权衡：
- BlockingQueue（如 LinkedBlockingQueue）：支持阻塞读写，适合生产者-消费者模型中需要等待的场景
- ConcurrentLinkedQueue：无锁、高性能，适合非阻塞、高吞吐场景
- ArrayBlockingQueue：有界阻塞队列，适合资源受限的场景
基本上就这些。ConcurrentLinkedQueue 是实现高性能并发队列的优选之一，尤其适合不需要阻塞操作的异步任务处理系统。理解其非阻塞特性和使用限制，能帮助你在实际项目中更合理地应用它。不复杂但容易忽略的是：别依赖 size() 做精确判断，也别忘了处理 poll() 返回 null 的情况。
