前言

前几天看见一个高级Java面试题，我觉得很有代表意义。既考察了面试者的基本锁机制运用，也了解了阻塞队列的产生实现原理。先分享出来，以供鉴赏。

面试题：实现一个自定义的阻塞队列，它应该支持以下功能：
添加元素到队列末尾（如果队列已满，则阻塞添加线程直到有空间）
从队列头部移除元素（如果队列为空，则阻塞获取元素的线程直到有元素可消费）
查询队列是否为空
查询队列是否已满
要求使用Java的ReentrantLock和Condition类来实现线程间的同步。

实战演示

既然题目说到了使用Java的ReentrantLock和Condition类来实现线程间的同步，也就为我们指明了方向，直接可以按照题目的思路进行编码。当然，如果题目没有要求使用技术点，你是否知道还有哪些方式可以实现这个阻塞队列呢？

自定义阻塞队列编码如下：

/*** CustomBlockingQueue* @author senfel* @date 2024/2/21 12:50*/
public class CustomBlockingQueue<T> {private final LinkedList<T> queue = new LinkedList<>();private final int capacity;private final ReentrantLock lock = new ReentrantLock();private final Condition notEmpty = lock.newCondition();private final Condition notFull = lock.newCondition();public CustomBlockingQueue(int capacity) {this.capacity = capacity;}/*** put* @author senfel* @date 2024/2/21 12:52* @return void*/public void put(T item) throws InterruptedException {lock.lock();try {while (queue.size() == capacity) {notFull.await();}if (queue.isEmpty()) {notEmpty.signal(); // 如果之前有等待的消费者，现在可以唤醒了}queue.addLast(item);} finally {lock.unlock();}}/*** take* @author senfel* @date 2024/2/21 12:59* @return void*/public T take() throws InterruptedException {lock.lock();try {while (queue.isEmpty()) {notEmpty.await();}if (queue.size() == capacity) {notFull.signal(); // 如果之前有等待的生产者，现在可以唤醒了}return queue.removeFirst();} finally {lock.unlock();}}public boolean isEmpty() {lock.lock();try {return queue.isEmpty();} finally {lock.unlock();}}public boolean isFull() {lock.lock();try {return queue.size() == capacity;} finally {lock.unlock();}}
}

写在最后

这个CustomBlockingQueue类使用了Java并发包中的ReentrantLock作为锁机制，并通过其条件变量notEmpty和notFull分别管理队列空和队列满的情况。当队列满时，调用put方法会阻塞，直到有空间；当队列空时，调用take方法也会阻塞，直到有元素可消费。同时，当添加或删除元素改变队列状态时，会适当调整对应的条件变量以唤醒等待的线程。