java中的阻塞队列

拼搏现实的明天。 2021-06-24 16:09 319阅读 0赞

今天开始在学习Java的阻塞队列，所以先进行一些了解

阻塞队列提供了可阻塞的put和take方法，以及支持定时的offer和poll方法。如果队列已经满了，那么put方法会阻塞到有可用空间；如果队列为空，take方法会一直阻塞到有可用元素。阻塞队列非常实用于生产者和消费者模式，当有数据生成时，生产者把数据放入队列，当消费者需要数据时，从队列中进行获取。而生产者不需要知道消费者的状态，同样消费者也不需要知道生产者的状态。当然消费者和生产者是相对的，假如生产者的速率大于消费者，那么当队列满了的时候，生产者可以转为消费者，将队列中的数据取出进行消费者的处理，这个道理同样适用于消费者。

下面来介绍阻塞队列的四种处理方式：

1.抛出异常，当调用add(e)方法将元素添加到队列中时，如果队列已经满了，则会抛出IllegalStateException；当调用remove(e)方法将元素从队列中移除时，如果指定的元素不存在时，则会抛出NullPointerException。当调用element()方法获取队列的头部时，如果队列为空，则会抛出NullPointerException。

2.特殊值，当调用offer(e)方法将元素插入到队列中时，如果该元素已经添加到该队列，则返回true，否则返回false；当调用poll()方法移除队列的头部时，返回被移除的队列头部；当调用peek()方法获取队列头部时，返回队列头部，如果队列为空，则返回null。

3.阻塞，即如前文介绍的put和take方法。

4.超时，当调用offer(e,time,unit)方法将指定元素插入到队列中，在插入之前等待以unit为单位的time超时时间，如果成功，返回true，如果超时，则返回false；当调用poll(time,unit)方法返回并且移除队列头部时，等待以unit为单位的time时间内的可用元素，如果成功，返回队列头部，如果超时，返回false。

接下来介绍几种常见的队列类型：

1.LinkedBlockingQueue：基于LinkedList的FIFO（first input，first out）的队列。

2.ArrayBlockingQueue：基于ArrayList的FIFO队列。

3.ProrityBlockingQueue：按照优先级排序的队列，可以按照元素的自然顺序或者元素实现的Comparable方式排序。

4.SynchronousQueue：实际上不是一个真正的队列，因为不会为队列中的元素进行维护，而它维护的是一组线程，这些线程在等待着把元素加入或者移除队列，它会直接将元素从生产者交付给消费者，而不需要一个中间件，从而会降低数据从生产者到消费者之间的延迟，但是该队列只适用于有足够多的消费者，并且总有一个消费者准备好获取交付的元素时的场合。

一些队列的基础知识介绍就到此，接下来会进入到更深入的了解方式。