【Java面试】Queue接口

逃离我推掉我的手 2024-03-29 15:19 99阅读 0赞

#### 文章目录 ####

*  BlockingQueue中有哪些方法，为什么这样设计？
 *  BlockingQueue是怎么实现的？

## BlockingQueue中有哪些方法，为什么这样设计？ ##

先看一眼结构，再看具体的分析  
![在这里插入图片描述][62801414b8804d02ba73ae0a923a03e5.png]  
![在这里插入图片描述][af28b8a8c6d244b99ee5092653d1fe76.png]  
![在这里插入图片描述][5f60153c4e884d90b21ede643e8585a6.png]  
为了应对不同的业务场景，BlockingQueue 提供了4 组不同的方法用于插入、移除以及对队列中的元素进行检查。如果请求的操作不能得到立即执行的话，每组方法的表现是不同的。这些方法如下：  
![在这里插入图片描述][15473e6fbd6541468260afb2d2c3f066.png]  
四组不同的行为方式含义如下：

*  抛异常：如果操作无法立即执行，则抛一个异常；
 *  特定值：如果操作无法立即执行，则返回一个特定的值(一般是 true / false)。
 *  阻塞：如果操作无法立即执行，则该方法调用将会发生阻塞，直到能够执行；
 *  超时：如果操作无法立即执行，则该方法调用将会发生阻塞，直到能够执行。但等待时间不会超过给定值，并返回一个特定值以告知该操作是否成功(典型的是true / false)。

## BlockingQueue是怎么实现的？ ##

BlockingQueue是一个接口，它的实现类有ArrayBlockingQueue、DelayQueue、 LinkedBlockingQueue、PriorityBlockingQueue、SynchronousQueue等。它们的区别主要体现在存储结构上或对元素操作上的不同，但是对于put与take操作的原理是类似的。下面以ArrayBlockingQueue为例，来说明BlockingQueue的实现原理。

首先看一下ArrayBlockingQueue的构造函数，它初始化了put和take函数中用到的关键成员变量，这两个变量的类型分别是ReentrantLock和Condition。ReentrantLock是AbstractQueuedSynchronizer（AQS）的子类，它的newCondition函数返回的Condition实例，是定义在AQS类内部的ConditionObject类，该类可以直接调用AQS相关的函数。

public ArrayBlockingQueue(int capacity, boolean fair) {    
      if (capacity <= 0)   
           throw new IllegalArgumentException();     
            this.items = new Object[capacity];     
             lock = new ReentrantLock(fair);      
             notEmpty = lock.newCondition();      
             notFull = lock.newCondition();  
             }

put函数会在队列末尾添加元素，如果队列已经满了，无法添加元素的话，就一直阻塞等待到可以加入为止。函数的源码如下所示。我们会发现put函数使用了wait/notify的机制。与一般生产者-消费者的实现方式不同，同步队列使用ReentrantLock和Condition相结合的机制，即先获得锁，再等待，而不是synchronized和wait的机制。

public void put(E e) throws InterruptedException {     
     checkNotNull(e);    
       final ReentrantLock lock = this.lock;     
        lock.lockInterruptibly();     
         try {       
            while (count == items.length)       
                   notFull.await();         
                    enqueue(e);      
                    } finally {      
                        lock.unlock();      
                        }  }

再来看一下消费者调用的take函数，take函数在队列为空时会被阻塞，一直到阻塞队列加入了新的元素。

public E take() throws InterruptedException {  
        final ReentrantLock lock = this.lock;     
         lock.lockInterruptibly();  
             try {    
                   while (count == 0)      
                           notEmpty.await(); 
                                    return dequeue();   
                                       } finally {
                                                 lock.unlock();  
                                                     }  }

await操作：

我们发现ArrayBlockingQueue并没有使用Object.wait，而是使用的Condition.await，这是为什么呢？Condition对象可以提供和Object的wait和notify一样的行为，但是后者必须先获取synchronized这个内置的monitor锁才能调用，而Condition则必须先获取ReentrantLock。这两种方式在阻塞等待时都会将相应的锁释放掉，但是Condition的等待可以中断，这是二者唯一的区别。

我们先来看一下Condition的await函数，await函数的流程大致如下图所示。await函数主要有三个步骤，一是调用addConditionWaiter函数，在condition wait queue队列中添加一个节点，代表当前线程在等待一个消息。然后调用fullyRelease函数，将持有的锁释放掉，调用的是AQS的函数。最后一直调用isOnSyncQueue函数判断节点是否被转移到sync queue队列上，也就是AQS中等待获取锁的队列。如果没有，则进入阻塞状态，如果已经在队列上，则调用acquireQueued函数重新获取锁。  
![在这里插入图片描述][06e9372c773145d6b93ba9a06b31d537.png]

signal操作：

signal函数将condition wait queue队列中队首的线程节点转移等待获取锁的sync queue队列中。这样的话，await函数中调用isOnSyncQueue函数就会返回true，导致await函数进入最后一步重新获取锁的状态。

我们这里来详细解析一下condition wait queue和sync queue两个队列的设计原理。condition wait queue是等待消息的队列，因为阻塞队列为空而进入阻塞状态的take函数操作就是在等待阻塞队列不为空的消息。而sync queue队列则是等待获取锁的队列，take函数获得了消息，就可以运行了，但是它还必须等待获取锁之后才能真正进行运行状态。

signal函数其实就做了一件事情，就是不断尝试调用transferForSignal函数，将condition wait queue队首的一个节点转移到sync queue队列中，直到转移成功。因为一次转移成功，就代表这个消息被成功通知到了等待消息的节点。

signal函数的示意图如下所示。

![在这里插入图片描述][8073e3ed873a4a5d8daafeea3e887c6b.png]

[62801414b8804d02ba73ae0a923a03e5.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/28/6360e72602c74f9db895bb327552a166.png
[af28b8a8c6d244b99ee5092653d1fe76.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/28/8f405980848049929abf45732f9a1826.png
[5f60153c4e884d90b21ede643e8585a6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/28/f751fc6c6c5745e8a1defc8fd5598edb.png
[15473e6fbd6541468260afb2d2c3f066.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/28/95c070771d7e4badb830566eb9277971.png
[06e9372c773145d6b93ba9a06b31d537.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/28/7ded22efe674428a8ec5b9f8d12e3115.png
[8073e3ed873a4a5d8daafeea3e887c6b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/28/2931ed7f1759431d988327a9717f6281.png