当前位置：首页 > 文章列表 > 文章 > java教程 > JavaLinkedBlockingQueue使用全解析

JavaLinkedBlockingQueue使用全解析

2026-01-26 12:22:43 0浏览收藏

从现在开始，努力学习吧！本文《Java中LinkedBlockingQueue使用详解》主要讲解了等等相关知识点，我会在golang学习网中持续更新相关的系列文章，欢迎大家关注并积极留言建议。下面就先一起来看一下本篇正文内容吧，希望能帮到你！

LinkedBlockingQueue是Java并发包中线程安全的链表阻塞队列，适用于生产者-消费者模型；支持有界/无界构造，提供put/take等阻塞操作及offer/poll等非阻塞操作，不支持null元素。

java中linkedblockingqueue用法

LinkedBlockingQueue 是 Java 并发包（java.util.concurrent）中一个线程安全的、基于链表实现的阻塞队列。它常用于生产者-消费者模型，支持多线程环境下高效、安全的数据传递。

基本用法：创建与添加元素

可以指定容量（有界）或不指定（默认为 Integer.MAX_VALUE，即近似无界）。常用构造方式：

new LinkedBlockingQueue() —— 默认容量为最大整数，几乎无界
new LinkedBlockingQueue(10) —— 明确指定容量为 10，满时阻塞插入

添加元素常用方法：

put(E e)：阻塞式插入，队列满时线程等待，直到有空间
offer(E e)：非阻塞插入，成功返回 true，失败（如已满）返回 false
offer(E e, long timeout, TimeUnit unit)：带超时的插入，超时前未插入成功则返回 false

获取与移除元素

消费端常用操作：

take()：阻塞式获取并移除头元素，队列空时等待，直到有元素可用
poll()：非阻塞获取并移除头元素，为空时返回 null
poll(long timeout, TimeUnit unit)：带超时的获取，超时未取到则返回 null

注意：element() 和 peek() 只查看不移除，但 element() 在队列为空时抛出异常，peek() 返回 null，一般推荐用 peek() 避免异常。

典型生产者-消费者场景示例

两个线程协作：一个生产数据放入队列，一个从队列取出处理：

LinkedBlockingQueue<String> queue = new LinkedBlockingQueue<>(5);

// 生产者线程
new Thread(() -> {
    try {
        for (int i = 0; i < 10; i++) {
            queue.put("item-" + i); // 自动阻塞等待空位
            System.out.println("Produced: item-" + i);
            Thread.sleep(100);
        }
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
    }
}).start();

// 消费者线程
new Thread(() -> {
    try {
        while (true) {
            String item = queue.take(); // 自动阻塞等待元素
            System.out.println("Consumed: " + item);
            Thread.sleep(200);
        }
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
    }
}).start();

该例子体现了 put/take 的天然阻塞协调能力，无需额外加锁或 wait/notify。

注意事项与常见误区

使用时需留意以下几点：

容量设置要合理：无界队列（默认）可能导致内存溢出，尤其在生产快于消费时
队列本身线程安全，但其中存储的对象若被多线程共享修改，仍需自行保证其线程安全性
size() 方法返回当前元素个数，但并发环境下该值可能瞬间过期，**不适合用作条件判断依据**（比如 if (queue.size() < 5) queue.offer(...) 不安全）
不支持 null 元素，插入 null 会直接抛出 NullPointerException

基本上就这些。掌握 put/take 的阻塞语义，就能稳稳用好它。

以上就是《JavaLinkedBlockingQueue使用全解析》的详细内容，更多关于java的资料请关注golang学习网公众号！

java