当前位置：首页 > 文章列表 > 文章 > java教程 > Java并发队列教程：ConcurrentLinkedQueue详解

Java并发队列教程：ConcurrentLinkedQueue详解

2025-09-24 17:05:43 0浏览收藏

**Java并发队列使用教程：ConcurrentLinkedQueue详解** 深入了解Java并发编程，`ConcurrentLinkedQueue`是你的得力助手！作为`java.util.concurrent`包下的线程安全、无界非阻塞队列，`ConcurrentLinkedQueue`基于链表结构，在高并发生产者-消费者模型中表现出色。本文将详细介绍`ConcurrentLinkedQueue`的创建、常用方法（如`add/offer`入队、`poll`出队、`peek`查看队首等）及多线程环境下的典型应用，并着重讲解其注意事项，包括避免`null`元素、`size()`方法的并发不精确性、以及非阻塞特性。掌握`ConcurrentLinkedQueue`，助力你的高并发应用开发，提升系统性能！

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

如何在Java中使用ConcurrentLinkedQueue

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  {
    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();