在Java中如何使用LinkedBlockingQueue在多线程间传递数据_LinkedBlockingQueue实践分享-java教程-PHP中文网

在Java中如何使用LinkedBlockingQueue在多线程间传递数据_LinkedBlockingQueue实践分享

P粉602998670

发布： 2025-11-07 11:28:02

原创

206人浏览过

LinkedBlockingQueue是Java中基于链表的线程安全阻塞队列，支持有界或无界容量，适用于生产者-消费者模型；通过put/take方法实现阻塞式数据传递，避免轮询开销，常用于日志收集、任务调度和异步处理场景，配合超时控制可提升系统响应性，需注意设置合理容量防止内存溢出。

在java中如何使用linkedblockingqueue在多线程间传递数据_linkedblockingqueue实践分享

在多线程编程中，安全高效地传递数据是关键。Java 提供了多种线程安全的队列实现，LinkedBlockingQueue 是其中使用广泛的一种。它基于链表结构，支持高并发场景下的生产者-消费者模型，非常适合在线程间传递数据。

什么是 LinkedBlockingQueue

LinkedBlockingQueue 是 java.util.concurrent 包中的一个阻塞队列实现，内部采用链表存储元素。它的主要特点是：

线程安全：所有操作都通过锁机制保证原子性
支持阻塞操作：当队列为空时，取元素的操作会等待；当队列为满时，插入操作也会等待（如果设置了容量）
可选有界：可以指定队列最大容量，不指定则默认为 Integer.MAX_VALUE（近似无界）

这些特性让它天然适合用于多线程环境下的数据交换。

基本用法示例：生产者与消费者

下面是一个典型的生产者-消费者模型，使用 LinkedBlockingQueue 在两个线程间传递字符串数据。

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

import java.util.concurrent.LinkedBlockingQueue;

public class ProducerConsumerExample {
    public static void main(String[] args) {
        // 创建一个有界队列，最多存放10个元素
        LinkedBlockingQueue<String> queue = new LinkedBlockingQueue<>(10);

        // 生产者线程
        Thread producer = new Thread(() -> {
            try {
                for (int i = 1; i <= 5; i++) {
                    String data = "消息-" + i;
                    queue.put(data); // 阻塞式入队
                    System.out.println("生产：" + data);
                    Thread.sleep(500); // 模拟处理时间
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        });

        // 消费者线程
        Thread consumer = new Thread(() -> {
            try {
                while (true) {
                    String data = queue.take(); // 阻塞式出队
                    System.out.println("消费：" + data);
                    if (data.endsWith("-5")) break; // 结束条件
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        });

        producer.start();
        consumer.start();

        try {
            producer.join();
            consumer.join();
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
}

登录后复制

在这个例子中，生产者调用 put() 方法将数据放入队列，如果队列满了，线程会自动阻塞。消费者调用 take() 方法获取数据，如果队列为空，也会阻塞等待。这种方式避免了轮询带来的资源浪费。