上一篇中主要介绍了JDK中的Queue的基本信息,本篇主要对JDK中的BlockingQueue作简单的介绍。
一、 什么是BlockingQueue?
顾名思义,BlockingQueue就是阻塞队列,相对于非阻塞队列,提供了阻塞增删element的特有方法。具体表现为:在向队列中插入element时,如果队列已满,则阻塞等待,直到队列非满时,插入成功;在从队列中取element时,如果队列为空,则阻塞等待,直到队列非空,才取出element。
二、BlockingQueue的特征:
BlockingQueue从本质上讲还是一个Queue,所以拥有Queue的一切特征,不同之处在于其针对队列的增删操作,在特定条件下的行为不同,如上所述,插入时,若队列已满,则阻塞,直到队列非满;删除时,若队列为空,则阻塞,直到队列非空。
三、JDK中BlockingQueue的继承关系:
如下图所示:
四、 BlockingQueue中的API:
BlockingQueue中的API可以概括为以下四种类型:
1、抛异常,如add(e)、remove(),element()
2、返回特定的值,如offer(e)、poll()和peek()
3、阻塞当前线程,直到操作成功,如put(e)、take()
4、给定一个最大时间,在这个时间内阻塞当前线程,超过最大时间还未成功,则放弃,如offer(e, time, unit)、poll(time, unit)
具体如下图:
五、BlockingQueue的一般性约束:
1、与非阻塞队列一样,BlockingQueue也不支持null元素的队列操作;
2、BlockingQueue可以被实现为有界队列,若未指定为有界队列,则默认的队列容量为Integer.MAX_VALUE;
3、 BlockingQueue经常被用作支持集合操作的 生产者-消费者 模型队列,但是这样的操作通常不会很高效;
4、BlockingQueue是线程安全的,除了集合中批量的操作方法addAll()、removeAll()、retainAll()和containsAll(),其中的所有队列操作方法都是使用内部锁或者其他并行控制实现的;
5、BlockingQueue本质上不支持任何类型的“close”或“shutdown”操作以表示将不能再添加任何element;
6、内存一致性影响:与其他并发集合一样,在一个线程将对象放入BlockingQueue的操作happen-before另一个访问或删除该元素的线程的操作。
7、在使用BlockingQueue实现的生产者-消费者模型队列中,天生支持线程安全的多个生产者和多个消费者操作;