如何在Java中使用ConcurrentLinkedQueue-java教程-PHP中文网

如何在Java中使用ConcurrentLinkedQueue

P粉602998670

发布： 2025-09-25 23:25:01

原创

740人浏览过

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<String> queue = new ConcurrentLinkedQueue<>();

// 使用已有集合初始化
List<String> list = Arrays.asList("a", "b", "c");
ConcurrentLinkedQueue<String> 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. 在多线程环境下的典型应用

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

易森网络企业版

如果您是新用户，请直接将本程序的所有文件上传在任一文件夹下，Rewrite 目录下放置了伪静态规则和筛选器，可将规则添加进IIS，即可正常使用，不用进行任何设置；(可修改图片等)默认的管理员用户名、密码和验证码都是：yeesen系统默认关闭，请上传后登陆后台点击“核心管理”里操作如下:进入“配置管理”中的&ld

查看详情

立即学习“Java免费学习笔记（深入）”；

ConcurrentLinkedQueue<Integer> 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();

登录后复制