【java多线程】队列系统之说说队列Queue

转载：http://benjaminwhx.com/2018/05/05/%E8%AF%B4%E8%AF%B4%E9%98%9F%E5%88%97Queue/

一、简介

Queue（队列）：一种特殊的线性表，它只容许在表的前端（front）进行删除操做，只容许在表的后端（rear）进行插入操做。进行插入操做的端称为队尾，进行删除操做的端称为队头。

每一个元素老是从队列的rear端进入队列，而后等待该元素以前的全部元素出队以后，当前元素才能出对，遵循先进先出（FIFO）原则。

下面是Queue类的继承关系图：

图中咱们能够看到，最上层是Collection接口，Queue知足集合类的全部方法：

• add(E e)：增长元素；
• remove(Object o)：删除元素；
• clear()：清除集合中全部元素；
• size()：集合元素的大小；
• isEmpty()：集合是否没有元素；
• contains(Object o)：集合是否包含元素o。

二、队列

2.一、Queue

Queue：队列的上层接口，提供了插入、删除、获取元素这3种类型的方法，并且对每一种类型都提供了两种方式，先来看看插入方法：

• add(E e)：插入元素到队尾，插入成功返回true，没有可用空间抛出异常 IllegalStateException。
• offer(E e)： 插入元素到队尾，插入成功返回true，不然返回false。

add和offer做为插入方法的惟一不一样就在于队列满了以后的处理方式。add抛出异常，而offer返回false。

再来看看删除和获取元素方法（和插入方法相似）：

• remove()：获取并移除队首的元素，该方法和poll方法的不一样之处在于，若是队列为空该方法会抛出异常，而poll不会。
• poll()：获取并移除队首的元素，若是队列为空，返回null。
• element()：获取队列首的元素，该方法和peek方法的不一样之处在于，若是队列为空该方法会抛出异常，而peek不会。
• peek()：获取队列首的元素，若是队列为空，返回null。

若是队列是空，remove和element方法会抛出异常，而poll和peek返回null。

固然，Queue只是单向队列，为了提供更强大的功能，JDK在1.6的时候新增了一个双向队列Deque，用来实现更灵活的队列操做。

2.二、Deque

Deque在Queue的基础上，增长了如下几个方法：

• addFirst(E e)：在前端插入元素，异常处理和add同样；
• addLast(E e)：在后端插入元素，和add同样的效果；
• offerFirst(E e)：在前端插入元素，异常处理和offer同样；
• offerLast(E e)：在后端插入元素，和offer同样的效果；
• removeFirst()：移除前端的一个元素，异常处理和remove同样；
• removeLast()：移除后端的一个元素，和remove同样的效果；
• pollFirst()：移除前端的一个元素，和poll同样的效果；
• pollLast()：移除后端的一个元素，异常处理和poll同样；
• getFirst()：获取前端的一个元素，和element同样的效果；
• getLast()：获取后端的一个元素，异常处理和element同样；
• peekFirst()：获取前端的一个元素，和peek同样的效果；
• peekLast()：获取后端的一个元素，异常处理和peek同样；
• removeFirstOccurrence(Object o)：从前端开始移除第一个是o的元素；
• removeLastOccurrence(Object o)：从后端开始移除第一个是o的元素；
• push(E e)：和addFirst同样的效果；
• pop()：和removeFirst同样的效果。

能够发现，其实不少方法的效果都是同样的，只不过名字不一样。好比Deque为了实现Stack的语义，定义了push和pop两个方法。

三、阻塞队列

3.一、BlockingQueue

BlockingQueue（阻塞队列），在Queue的基础上实现了阻塞等待的功能。它是JDK 1.5中加入的接口，它是指这样的一个队列：当生产者向队列添加元素但队列已满时，生产者会被阻塞；当消费者从队列移除元素但队列为空时，消费者会被阻塞。

先给出BlockingQueue新增的方法：

• put(E e)：向队尾插入元素。若是队列满了，阻塞等待，直到被中断为止。
• boolean offer(E e, long timeout, TimeUnit unit)：向队尾插入元素。若是队列满了，阻塞等待timeout个时长，若是到了超时时间尚未空间，抛弃该元素。
• take()：获取并移除队首的元素。若是队列为空，阻塞等待，直到被中断为止。
• poll(long timeout, TimeUnit unit)：获取并移除队首的元素。若是队列为空，阻塞等待timeout个时长，若是到了超时时间尚未元素，则返回null。
• remainingCapacity()：返回在无阻塞的理想状况下（不存在内存或资源约束）此队列能接受的元素数量，若是该队列是无界队列，返回Integer.MAX_VALUE。
• drainTo(Collection<? super E> c)：移除此队列中全部可用的元素，并将它们添加到给定 collection 中。
• drainTo(Collection<? super E> c, int maxElements)：最多今后队列中移除给定数量的可用元素，并将这些元素添加到给定 collection 中。

BlockingQueue最重要的也就是关于阻塞等待的几个方法，而这几个方法正好能够用来实现生产-消费的模型。

从图中咱们能够知道实现了BlockingQueue的类有如下几个：

• ArrayBlockingQueue：一个由数组结构组成的有界阻塞队列。
• LinkedBlockingQueue：一个由链表结构组成的有界阻塞队列。
• PriorityBlockingQueue：一个支持优先级排序的无界阻塞队列。
• SynchronousQueue：一个不存储元素的阻塞队列。
• DelayQueue：一个使用优先级队列实现的无界阻塞队列。

ArrayBlockingQueue

ArrayBlockingQueue是一个用数组实现的有界阻塞队列。此队列按照先进先出（FIFO）的原则对元素进行排序。默认状况下不保证访问者公平的访问队列，所谓公平访问队列是指阻塞的全部生产者线程或消费者线程，当队列可用时，能够按照阻塞的前后顺序访问队列，即先阻塞的生产者线程，能够先往队列里插入元素，先阻塞的消费者线程，能够先从队列里获取元素。一般状况下为了保证公平性会下降吞吐量。咱们可使用如下代码建立一个公平的阻塞队列：

ArrayBlockingQueue fairQueue = new  ArrayBlockingQueue(1000, true);

View Code

访问者的公平性是使用可重入锁实现的，代码以下：

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();
}

View Code

 

LinkedBlockingQueue

LinkedBlockingQueue是一个用链表实现的有界阻塞队列。此队列的默认和最大长度为Integer.MAX_VALUE。此队列按照先进先出的原则对元素进行排序。

PriorityBlockingQueue

PriorityBlockingQueue是一个支持优先级的无界队列。默认状况下元素采起天然顺序排列，也能够经过比较器comparator来指定元素的排序规则。元素按照升序排列。

SynchronousQueue

SynchronousQueue是一个不存储元素的阻塞队列。每个put操做必须等待一个take操做，不然不能继续添加元素。SynchronousQueue能够当作是一个传球手，负责把生产者线程处理的数据直接传递给消费者线程。队列自己并不存储任何元素，很是适合于传递性场景,好比在一个线程中使用的数据，传递给另一个线程使用，SynchronousQueue的吞吐量高于LinkedBlockingQueue 和 ArrayBlockingQueue。

DelayQueue

DelayQueue是一个支持延时获取元素的无界阻塞队列。队列使用PriorityQueue来实现。队列中的元素必须实现Delayed接口，在建立元素时能够指定多久才能从队列中获取当前元素。只有在延迟期满时才能从队列中提取元素。咱们能够将DelayQueue运用在如下应用场景：

• 缓存系统的设计：能够用DelayQueue保存缓存元素的有效期，使用一个线程循环查询DelayQueue，一旦能从DelayQueue中获取元素时，表示缓存有效期到了。
• 定时任务调度。使用DelayQueue保存当天将会执行的任务和执行时间，一旦从DelayQueue中获取到任务就开始执行，从好比TimerQueue就是使用DelayQueue实现的。

3.二、BlockingDeque

BlockingDeque（阻塞双端队列）在Deque的基础上实现了双端阻塞等待的功能。和第2节说的相似，BlockingDeque也提供了双端队列该有的阻塞等待方法：

• putFirst(E e)：在队首插入元素，若是队列满了，阻塞等待，直到被中断为止。
• putLast(E e)：在队尾插入元素，若是队列满了，阻塞等待，直到被中断为止。
• offerFirst(E e, long timeout, TimeUnit unit)：向队首插入元素。若是队列满了，阻塞等待timeout个时长，若是到了超时时间尚未空间，抛弃该元素。
• offerLast(E e, long timeout, TimeUnit unit)：向队尾插入元素。若是队列满了，阻塞等待timeout个时长，若是到了超时时间尚未空间，抛弃该元素。
• takeFirst()：获取并移除队首的元素。若是队列为空，阻塞等待，直到被中断为止。
• takeLast()：获取并移除队尾的元素。若是队列为空，阻塞等待，直到被中断为止。
• pollFirst(long timeout, TimeUnit unit)：获取并移除队首的元素。若是队列为空，阻塞等待timeout个时长，若是到了超时时间尚未元素，则返回null。
• pollLast(long timeout, TimeUnit unit)：获取并移除队尾的元素。若是队列为空，阻塞等待timeout个时长，若是到了超时时间尚未元素，则返回null。
• removeFirstOccurrence(Object o)：从队首开始移除第一个和o相等的元素。
• removeLastOccurrence(Object o)：从队尾开始移除第一个和o相等的元素。

从图中咱们能够知道实现了BlockingDeque的类有：

• LinkedBlockingDeque：一个由链表结构组成的双向阻塞队列。

3.三、TransferQueue

TransferQueue是JDK 1.7对于并发类库新增长的一个接口，它扩展自BlockingQueue，因此天然保持着阻塞队列的全部特性。

有人这样评价它：TransferQueue是是ConcurrentLinkedQueue、SynchronousQueue (公平模式下)、无界的LinkedBlockingQueues等的超集。

TransferQueue对比与BlockingQueue更强大的一点是，生产者会一直阻塞直到所添加到队列的元素被某一个消费者所消费（不只仅是添加到队列里就完事）。新添加的transfer方法用来实现这种约束。顾名思义，阻塞就是发生在元素从一个线程transfer到另外一个线程的过程当中，它有效地实现了元素在线程之间的传递（以创建Java内存模型中的happens-before关系的方式）。

咱们来看看该接口提供的标准方法：

• tryTransfer(E e)：若当前存在一个正在等待获取的消费者线程（使用take()或者poll()函数），使用该方法会即刻转移/传输对象元素e并当即返回true；若不存在，则返回false，而且不进入队列。这是一个不阻塞的操做。
• transfer(E e)：若当前存在一个正在等待获取的消费者线程，即马上移交之；不然，会插入当前元素e到队列尾部，而且等待进入阻塞状态，到有消费者线程取走该元素。
• tryTransfer(E e, long timeout, TimeUnit unit)：若当前存在一个正在等待获取的消费者线程，会当即传输给它;不然将插入元素e到队列尾部，而且等待被消费者线程获取消费掉；若在指定的时间内元素e没法被消费者线程获取，则返回false，同时该元素被移除。
• hasWaitingConsumer()：判断是否存在消费者线程。
• getWaitingConsumerCount()：获取全部等待获取元素的消费线程数量。

其实transfer方法在SynchronousQueue的实现中就已存在了,只是没有作为API暴露出来。SynchronousQueue有一个特性:它自己不存在容量,只能进行线程之间的元素传送。SynchronousQueue在执行offer操做时，若是没有其余线程执行poll，则直接返回false.线程之间元素传送正是经过transfer方法完成的。

TransferQueue相比SynchronousQueue用处更广、更好用，由于你能够决定是使用BlockingQueue的方法（例如put方法）仍是确保一次传递完成（即transfer方法）。在队列中已有元素的状况下，调用transfer方法，能够确保队列中被传递元素以前的全部元素都能被处理。

从图中咱们能够知道实现了TransferQueue的类有：

• LinkedTransferQueue：一个由链表结构组成的无界阻塞队列。

好了，队列的API先说到这里，下面我会另起一文重点说说阻塞队列的那些个实现类的原理。