17370845950

ConcurrentLinkedQueue是Java中线程安全的无界非阻塞队列，基于链表实现，适用于高并发生产者-消费者场景。1. 可通过无参构造创建空队列，或传入集合初始化元素。2. 提供线程安全的add/offer入队、poll出队、peek查看队首、size获取大小（并发下不精确）和isEmpty判断是否为空等方法。3. 典型应用为多生产者多消费者模型，生产者调用offer添加任务，消费者循环poll获取任务处理，配合sleep避免过度占用CPU。4. 注意事项：不允许null元素，否则抛NPE；size遍历计算，结果可能不准；不支持阻塞操作，需阻塞应选用LinkedBlockingQueue；迭代器弱一致，不抛ConcurrentModificationException但可能反映部分修改。该队列性能高，适合无需阻塞的高并发场景。

ConcurrentLinkedQueue 是 Java 中一个线程安全的无界非阻塞队列，位于 java.util.concurrent 包下。它基于链表结构实现，适用于高并发场景下的生产者-消费者模型。由于其非阻塞特性，多个线程可以同时进行入队和出队操作而不会阻塞彼此，性能较高。

1. 创建 ConcurrentLinkedQueue 实例

ConcurrentLinkedQueue 提供了两个构造方法：

• 无参构造：创建一个空队列
• 带集合参数的构造：将已有集合中的元素初始化到队列中

// 创建一个空的 ConcurrentLinkedQueue
ConcurrentLinkedQueue queue = new ConcurrentLinkedQueue<>();

// 使用已有集合初始化
List list = Arrays.asList("a", "b", "c");
ConcurrentLinkedQueue queue2 = new ConcurrentLinkedQueue<>(list);

2. 常用方法说明与使用

ConcurrentLinkedQueue 支持标准的队列操作，所有操作都是线程安全的：

• add(e) 或 offer(e)：将元素插入队尾，成功返回 true
• poll()：移除并返回队首元素，如果队列为空则返回 null
• peek()：返回队首元素但不移除，队列为空时返回 null
• size()：返回当前队列中的元素数量（注意：在并发环境下该值可能不精确）
• isEmpty()：判断队列是否为空

queue.offer("task1");
queue.offer("task2");

String task = queue.poll(); // 获取并移除 "task1"
if (task != null) {
    System.out.println("处理任务: " + task);
}

String next = queue.peek(); // 查看下一个任务，不移除
System.out.println("下一个任务: " + next);

3. 在多线程环境下的典型应用

常用于多个生产者线程添加任务、多个消费者线程处理任务的场景。

ConcurrentLinkedQueue tasks = new ConcurrentLinkedQueue<>();

// 生产者线程
Runnable producer = () -> {
    for (int i = 0; i < 5; i++) {
        tasks.offer(i);
        System.out.println("生产: " + i);
        try { Thread.sleep(100); } catch (InterruptedException e) {}
    }
};

// 消费者线程
Runnable consumer = () -> {
    while (true) {
        Integer task = tasks.poll();
        if (task != null) {
            System.out.println("消费: " + task);
        } else {
            // 队列暂时为空，可稍作等待或退出
            try { Thread.sleep(50); } catch (InterruptedException e) {}
        }
    }
};

// 启动多个线程
new Thread(producer).start();
new Thread(consumer).start();

4. 注意事项

虽然 ConcurrentLinkedQueue 是线程安全的，但在使用时仍需注意以下几点：

• 不能插入 null 元素，否则会抛出 NullPointerException
• size() 方法在并发调用时需要遍历整个链表，结果可能不准确，仅作参考
• 不支持阻塞操作，若需要阻塞功能应考虑使用 LinkedBlockingQueue
• 迭代器是弱一致性的，不会抛出 ConcurrentModificationException，但可能反映部分修改