一、概述
位于java.util.concurrent下,声明:public interface BlockingQueue<E> extends Queue<E>
支持两个附加操作的 Queue
,这两个操作是:获取元素时等待队列变为非空,以及存储元素时等待空间变得可用。
BlockingQueue 方法以四种形式出现,对于不能立即满足但可能在将来某一时刻可以满足的操作,这四种形式的处理方式不同:第一种是抛出一个异常,第二种是返回一个特殊值(null 或 false,具体取决于操作),第三种是在操作可以成功前,无限期地阻塞当前线程,第四种是在放弃前只在给定的最大时间限制内阻塞。下表中总结了这些方法:
抛出异常 | 特殊值 | 阻塞 | 超时 | |
插入 | add(e) |
offer(e) |
put(e) |
offer(e, time, unit) |
移除 | remove() |
poll() |
take() |
poll(time, unit) |
检查 | element() |
peek() |
不可用 | 不可用 |
BlockingQueue 可以是限定容量的。它在任意给定时间都可以有一个
remainingCapacity,超出此容量,便无法无阻塞地 put 附加元素。没有任何内部容量约束的 BlockingQueue 总是报告
Integer.MAX_VALUE 的剩余容量。
BlockingQueue 实现主要用于生产者-使用者队列,但它另外还支持
Collection
接口。因此,举例来说,使用
remove(x) 从队列中移除任意一个元素是有可能的。然而,这种操作通常不 会有效执行,只能有计划地偶尔使用,比如在取消排队信息时。
BlockingQueue 实现是线程安全的。所有排队方法都可以使用内部锁或其他形式的并发控制来自动达到它们的目的。然而,大量的 Collection 操作(addAll、containsAll、retainAll 和
removeAll)没有 必要自动执行,除非在实现中特别说明。因此,举例来说,在只添加了 c 中的一些元素后,addAll(c) 有可能失败(抛出一个异常)。
BlockingQueue 实质上不 支持使用任何一种“close”或“shutdown”操作来指示不再添加任何项。这种功能的需求和使用有依赖于实现的倾向。例如,一种常用的策略是:对于生产者,插入特殊的
end-of-stream 或 poison 对象,并根据使用者获取这些对象的时间来对它们进行解释。
以下是基于典型的生产者-使用者场景的一个用例。注意,BlockingQueue 可以安全地与多个生产者和多个使用者一起使用。
class Producer implements Runnable { private final BlockingQueue queue; Producer(BlockingQueue q) { queue = q; } public void run() { try { while(true) { queue.put(produce()); } } catch (InterruptedException ex) { ... handle ...} } Object produce() { ... } } class Consumer implements Runnable { private final BlockingQueue queue; Consumer(BlockingQueue q) { queue = q; } public void run() { try { while(true) { consume(queue.take()); } } catch (InterruptedException ex) { ... handle ...} } void consume(Object x) { ... } } class Setup { void main() { BlockingQueue q = new SomeQueueImplementation(); Producer p = new Producer(q); Consumer c1 = new Consumer(q); Consumer c2 = new Consumer(q); new Thread(p).start(); new Thread(c1).start(); new Thread(c2).start(); } }
内存一致性效果:当存在其他并发 collection 时,将对象放入 BlockingQueue
之前的线程中的操作
happen-before 随后通过另一线程从 BlockingQueue
中访问或移除该元素的操作。
此接口是 Java Collections Framework 的成员。
二、方法1、boolean
add(E e)
offer
。
e
- 要添加的元素 Collection.add(E)
的规定)
IllegalStateException
- 如果由于容量限制此时不能添加该元素
ClassCastException
- 如果指定元素的类不允许将其添加到此队列
NullPointerException
- 如果指定元素为 null
IllegalArgumentException
- 如果指定元素的某些属性不允许将其添加到此队列add(E)
,后者可能无法插入元素,而只是抛出一个异常。
e
- 要添加的元素 ClassCastException
- 如果指定元素的类不允许将其添加到此队列
NullPointerException
- 如果指定元素为 null
IllegalArgumentException
- 如果指定元素的某些属性不允许将其添加到此队列
e
- 要添加的元素 InterruptedException
- 如果在等待时被中断
ClassCastException
- 如果指定元素的类不允许将其添加到此队列
NullPointerException
- 如果指定元素为 null
IllegalArgumentException
- 如果指定元素的某些属性不允许将其添加到此队列
e
- 要添加的元素timeout
- 放弃之前等待的时间长度,以 unit 为时间单位unit
- 确定如何解释 timeout 参数的 TimeUnit InterruptedException
- 如果在等待时被中断
ClassCastException
- 如果指定元素的类不允许将其添加到此队列
NullPointerException
- 如果指定元素为 null
IllegalArgumentException
- 如果指定元素的某些属性不允许将其添加到此队列
InterruptedException
- 如果在等待时被中断timeout
- 放弃之前要等待的时间长度,用 unit 的时间单位表示unit
- 确定如何解释 timeout 参数的 TimeUnit InterruptedException
- 如果在等待时被中断
注意,不能 总是通过检查 remainingCapacity 来判断尝试插入元素是否成功,因为可能出现这样的情况:其他线程即将插入或移除一个元素。
Collection<E>
中的
remove
o
- 要从此队列移除的元素(如果存在) ClassCastException
- 如果指定元素的类与此队列不兼容(可选)
NullPointerException
- 如果指定元素为 null(可选)Collection<E>
中的
contains
o
- 检查是否包含在此队列中的对象 ClassCastException
- 如果指定元素的类与此队列不兼容(可选)
NullPointerException
- 如果指定元素为 null(可选)c
- 接收传输元素的 collection UnsupportedOperationException
- 如果指定 collection 不支持添加元素
ClassCastException
- 如果此队列元素的类不允许将其添加到指定 collection
NullPointerException
- 如果指定 collection 为 null
IllegalArgumentException
- 如果指定 collection 是此队列,或者此队列元素的某些属性不允许将其添加到指定 collectionc
- 接收传输元素的 collectionmaxElements
- 传输元素的最大数量 UnsupportedOperationException
- 如果指定 collection 不支持添加元素
ClassCastException
- 如果此队列元素的类不允许将其添加到指定 collection
NullPointerException
- 如果指定 collection 为 null
IllegalArgumentException
- 如果指定 collection 是此队列,或者此队列元素的某些属性不允许将其添加到指定 collection原文地址:http://blog.csdn.net/u010142437/article/details/42278497