在并发编程中，线程安全的队列是解决线程间任务传递和调度的关键工具之一。阻塞队列（BlockingQueue）作为一种线程安全的队列，实现了在并发环境下对共享数据的安全访问，广泛应用于生产者-消费者模型、任务调度和多线程计算中。本文将详细介绍阻塞队列的概念、常见实现、线程安全原理及与线程池的结合使用，帮助你全面掌握 Java 中阻塞队列的应用。
1. 什么是阻塞队列
阻塞队列（BlockingQueue）是一个线程安全的队列，它支持在特定条件下对队列的操作进行阻塞。BlockingQueue 接口继承自 Queue，并提供了几个核心方法：take()、put()、offer() 和 poll()，其中 take() 和 put() 是阻塞操作，能够在队列为空时等待数据，或在队列满时等待空闲空间。
public interface BlockingQueue<E> extends Queue<E> {
void put(E e) throws InterruptedException;
E take() throws InterruptedException;
boolean offer(E e);
E poll();
// 其他方法
}
应用场景：
- 生产者消费者模型：多个生产者线程将任务放入队列，多个消费者线程从队列中取出任务执行，队列的大小决定了系统的缓冲能力。
- 任务调度：队列可以用来调度和管理任务，保证任务的顺序执行和线程间的协调。
2. 主要的并发队列关系图
Java 提供了多种线程安全的队列，主要可以分为两类：
- 阻塞队列（BlockingQueue）
- 非阻塞队列（如
ConcurrentLinkedQueue）
这两类队列各自适用于不同的场景，阻塞队列适合于需要控制线程协作的场景，非阻塞队列则适合于高并发、高性能的无阻塞任务处理。
3. 阻塞队列的特点
阻塞队列的最大特点是它的阻塞操作，主要体现在以下两个方法：
- take()：如果队列为空，消费者线程会被阻塞，直到队列中有数据可用。
- put()：如果队列已满，生产者线程会被阻塞，直到队列有空闲空间。
这些方法的阻塞特性使得阻塞队列非常适合于生产者-消费者模型，它能够保证任务的有序执行，并且自动控制线程的执行顺序。
4. 常用方法
常见的 BlockingQueue 方法包括：
- add()：向队列中添加元素，队列已满时抛出异常。
- remove()：移除并返回队列头部的元素，队列为空时抛出异常。
- offer()：向队列中添加元素，队列已满时返回
false。 - poll()：移除并返回队列头部的元素，队列为空时返回
null。 - put()：向队列中添加元素，队列已满时阻塞当前线程，直到有空间可用。
- take()：从队列中获取并移除元素，队列为空时阻塞当前线程，直到有数据可用。
5. 常见阻塞队列
Java 提供了多种实现了 BlockingQueue 接口的常见阻塞队列，每种队列的实现都具有不同的特点，适用于不同的应用场景。
5.1 ArrayBlockingQueue
ArrayBlockingQueue 是一个有界阻塞队列，内部使用数组存储元素，具有固定的容量，适用于任务数已知且较为稳定的场景。
BlockingQueue<Integer> queue = new ArrayBlockingQueue<>(10);
5.2 LinkedBlockingQueue
LinkedBlockingQueue 是一个基于链表的阻塞队列，可以设置容量，容量默认值为 Integer.MAX_VALUE。适用于任务量动态变化的场景。
BlockingQueue<Integer> queue = new LinkedBlockingQueue<>(100);
5.3 SynchronousQueue
SynchronousQueue 是一种特殊的阻塞队列，其容量为 0。每次生产任务时，必须有消费者线程来接收该任务，否则生产者会被阻塞。适用于快速传递任务的场景。
BlockingQueue<Integer> queue = new SynchronousQueue<>();
5.4 PriorityBlockingQueue
PriorityBlockingQueue 是一个无界的阻塞队列，支持优先级排序，队列中的元素根据优先级进行排序，适用于需要处理优先级任务的场景。
BlockingQueue<Integer> queue = new PriorityBlockingQueue<>();
5.5 DelayQueue
DelayQueue 是一个支持延时任务的无界阻塞队列，任务可以设置延迟时间，任务到期后才会被消费。适用于定时任务调度的场景。
BlockingQueue<Delayed> queue = new DelayQueue<>();
6. 阻塞和非阻塞队列的并发安全原理
6.1 ArrayBlockingQueue 源码分析
ArrayBlockingQueue 内部使用数组存储元素，使用 ReentrantLock 和 Condition 实现并发控制。put() 和 take() 方法会通过 lock 锁住队列，阻塞操作使用 notFull 和 notEmpty 条件变量来控制线程的同步。
public void put(E e) throws InterruptedException {
lock.lockInterruptibly();
try {
while (count == items.length)
notFull.await();
enqueue(e);
} finally {
lock.unlock();
}
}
- ReentrantLock：提供了对队列的独占锁，确保线程在操作队列时是互斥的。
- Condition：通过
notFull和notEmpty条件变量来控制线程的等待和唤醒。
6.2 非阻塞队列 ConcurrentLinkedQueue
ConcurrentLinkedQueue 是一个无界的非阻塞队列，内部通过 CAS（Compare-And-Swap）机制实现线程安全，适用于高并发场景。它使用 compareAndSwapObject 方法进行原子操作，保证多个线程同时访问队列时不发生冲突。
public boolean offer(E e) {
final Node<E> newNode = new Node<>(e);
for (Node<E> t = tail, p = t;;) {
Node<E> q = p.next;
if (q == null) {
if (p.casNext(null, newNode)) {
if (p != t)
casTail(t, newNode);
return true;
}
}
p = q;
}
}
7. 线程池与阻塞队列
线程池与阻塞队列常常一起使用，阻塞队列作为线程池的任务队列，用于存储待处理的任务。常见的线程池类型及其与阻塞队列的配合关系如下：
| 线程池类型 | 阻塞队列类型 |
|---|---|
FixedThreadPool | LinkedBlockingQueue |
SingleThreadExecutor | LinkedBlockingQueue |
CachedThreadPool | SynchronousQueue |
ScheduledThreadPool | DelayWorkQueue |
SingleThreadScheduledExecutor | DelayedWorkQueue |
7.1 LinkedBlockingQueue
适用于 FixedThreadPool 和 SingleThreadExecutor，由于这两个线程池的线程数固定，任务队列的容量可以设置较大，确保不会因为队列满而拒绝任务。
7.2 SynchronousQueue
适用于 CachedThreadPool，它的容量为 0，每个任务都会立即被执行，因此线程池的线程数可以动态变化。
7.3 DelayWorkQueue
适用于定时任务，如 ScheduledThreadPool 和 SingleThreadScheduledExecutor，能够根据任务的延迟时间进行调度。
总结
阻塞队列是并发编程中的一个重要工具，它通过线程安全的队列机制，保证了在多线程环境下的数据传递和协调。Java 提供了多种实现方式，如 ArrayBlockingQueue、LinkedBlockingQueue、SynchronousQueue 等，可以根据不同的业务需求选择合适的阻塞队列类型。掌握阻塞队列的使用和原理，能够帮助你构建更加高效和可靠的并发程序。
