BlockingQueue是Java中用于多线程安全通信的阻塞队列接口，通过put()和take()等方法实现线程阻塞与唤醒，简化生产者-消费者模型的实现。
在多线程编程中，线程之间的安全通信是一个核心问题。Java 提供了 BlockingQueue 接口及其实现类来简化这一过程。它不仅是一个线程安全的队列，还能在队列为空或满时自动阻塞线程，从而实现生产者-消费者模型的高效协作。
BlockingQueue 是什么？
BlockingQueue 是 java.util.concurrent 包下的一个接口，继承自 Queue，专为多线程环境设计。它的主要特性包括：
- 线程安全：所有操作都保证在并发环境下安全执行。
- 阻塞操作：当获取元素而队列为空时，取元素的线程会等待；当插入元素而队列满时，插入线程也会等待。
- 支持超时：可以设置操作的等待时间，避免无限期阻塞。
- ArrayBlockingQueue：基于数组的有界阻塞队列。
- LinkedBlockingQueue：基于链表的可选有界阻塞队列，默认容量为 Integer.MAX_VALUE。
- SynchronousQueue：不存储元素的阻塞队列，每个插入必须等待另一个线程的移除。
- PriorityBlockingQueue：支持优先级排序的无界阻塞队列。
使用 BlockingQueue 实现生产者-消费者模型
这是 BlockingQueue 最典型的应用场景。一个或多个生产者线程向队列添加任务，一个或多个消费者线程从队列取出并处理任务。
示例代码：
立即学习“Java免费学习笔记（深入）”；
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ArrayBlockingQueue;
// 共享队列
BlockingQueue<String> queue = new ArrayBlockingQueue<>(10);
// 生产者线程
Thread producer = new Thread(() -> {
try {
for (int i = 1; i <= 5; i++) {
String task = "任务-" + i;
queue.put(task); // 阻塞式入队
System.out.println("生产：" + task);
Thread.sleep(500); // 模拟耗时
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
});
// 消费者线程
Thread consumer = new Thread(() -> {
try {
while (true) {
String task = queue.take(); // 阻塞式出队
System.out.println("消费：" + task);
if (task.equals("任务-5")) break; // 结束条件
Thread.sleep(800);
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
});
// 启动线程
producer.start();
consumer.start();
try {
producer.join();
consumer.join();
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
在这个例子中，put() 和 take() 方法会自动处理线程阻塞与唤醒，无需手动使用 synchronized 或 wait/notify。
关键方法说明
BlockingQueue 提供了几组不同的方法来处理插入、移除和检查操作，行为不同：
- put(e)：将元素插入队列，如果队列满则阻塞直到可用。
- take()：从队列获取并移除元素，如果队列空则阻塞。
- offer(e, timeout, unit)：尝试在指定时间内插入元素，成功返回 true，超时返回 false。
- poll(timeout, unit)：尝试在指定时间内获取元素，超时返回 null。
- offer(e) 和 poll()：非阻塞操作，立即返回结果。
根据业务需求选择合适的方法。例如，在需要控制响应时间的系统中，使用带超时的版本更安全。
实际应用建议
在真实项目中使用 BlockingQueue 时，注意以下几点：
- 选择合适的实现类：如果需要固定大小，用 ArrayBlockingQueue；如果希望高吞吐且不限大小（注意内存），可用 LinkedBlockingQueue。
- 合理设置队列容量：过小容易阻塞，过大可能占用过多内存。
- 处理中断异常：调用 put/take 等方法时可能抛出 InterruptedException，应妥善处理并考虑恢复中断状态。
- 配合线程池使用：常用于 ExecutorService 的工作队列，实现任务调度。
基本上就这些。BlockingQueue 封装了复杂的同步逻辑，让开发者能更专注于业务本身。掌握它的使用，是构建稳定多线程应用的重要一步。
