JDK中的Queue简析--BlockingQueue(2)

上一篇中主要介绍了JDK中的Queue的基本信息,本篇主要对JDK中的BlockingQueue作简单的介绍。

一、 什么是BlockingQueue?

        顾名思义,BlockingQueue就是阻塞队列,相对于非阻塞队列,提供了阻塞增删element的特有方法。具体表现为:在向队列中插入element时,如果队列已满,则阻塞等待,直到队列非满时,插入成功;在从队列中取element时,如果队列为空,则阻塞等待,直到队列非空,才取出element。

二、BlockingQueue的特征:

        BlockingQueue从本质上讲还是一个Queue,所以拥有Queue的一切特征,不同之处在于其针对队列的增删操作,在特定条件下的行为不同,如上所述,插入时,若队列已满,则阻塞,直到队列非满;删除时,若队列为空,则阻塞,直到队列非空。

三、JDK中BlockingQueue的继承关系:

        如下图所示:


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中的API

五、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实现的生产者-消费者模型队列中,天生支持线程安全的多个生产者和多个消费者操作;

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容