E
- 在此集合中保存的元素的类型
public class ArrayBlockingQueue<E> extends AbstractQueue<E> implements BlockingQueue<E>, Serializable
这是一个经典的“有界缓冲区”,其中固定大小的数组保存由生产者插入的元素并由消费者提取。 创建后,容量无法更改。 尝试put
成满的队列的元件将导致在操作阻挡; 尝试take
从空队列的元件将类似地阻塞。
此类支持可选的公平策略,用于订购等待的生产者和消费者线程。 默认情况下,此订单不能保证。 然而,以公平设置为true
的队列以FIFO顺序授予线程访问权限。 公平性通常会降低吞吐量,但会降低变异性并避免饥饿。
该类及其迭代器实现了Collection
和Iterator
接口的所有可选方法。
这个类是Java Collections Framework的成员。
Constructor and Description |
---|
ArrayBlockingQueue(int capacity)
创建具有给定(固定)容量和默认访问策略的
ArrayBlockingQueue 。
|
ArrayBlockingQueue(int capacity, boolean fair)
创建一个
ArrayBlockingQueue 具有给定(固定)容量和指定访问策略。
|
ArrayBlockingQueue(int capacity, boolean fair, Collection<? extends E> c)
创建一个
ArrayBlockingQueue 具有给定(固定)容量,指定访问策略和最初包含给定集合中的元素,添加在收集迭代器的遍历顺序。
|
Modifier and Type | Method and Description |
---|---|
boolean |
add(E e)
在插入此队列的尾部,如果有可能立即这样做不超过该队列的容量,返回指定的元素
true 成功时与抛出
IllegalStateException 如果此队列已满。
|
void |
clear()
从这个队列中原子地删除所有的元素。
|
boolean |
contains(Object o)
如果此队列包含指定的元素,则返回
true 。
|
int |
drainTo(Collection<? super E> c)
从该队列中删除所有可用的元素,并将它们添加到给定的集合中。
|
int |
drainTo(Collection<? super E> c, int maxElements)
最多从该队列中删除给定数量的可用元素,并将它们添加到给定的集合中。
|
Iterator<E> |
iterator()
以适当的顺序返回该队列中的元素的迭代器。
|
boolean |
offer(E e)
如果可以在不超过队列容量的情况下立即将其指定的元素插入该队列的尾部,则在成功时
false 如果该队列已满,则返回
true 。
|
boolean |
offer(E e, long timeout, TimeUnit unit)
在该队列的尾部插入指定的元素,等待指定的等待时间,以使空间在队列已满时变为可用。
|
E |
peek()
检索但不删除此队列的头,如果此队列为空,则返回
null 。
|
E |
poll()
检索并删除此队列的头,如果此队列为空,则返回
null 。
|
E |
poll(long timeout, TimeUnit unit)
检索并删除此队列的头,等待指定的等待时间(如有必要)使元素变为可用。
|
void |
put(E e)
在该队列的尾部插入指定的元素,如果队列已满,则等待空间变为可用。
|
int |
remainingCapacity()
返回此队列可以理想地(在没有内存或资源限制)的情况下接受而不阻止的附加元素数。
|
boolean |
remove(Object o)
从该队列中删除指定元素的单个实例(如果存在)。
|
int |
size()
返回此队列中的元素数。
|
Spliterator<E> |
spliterator()
返回此队列中的元素 Spliterator 。
|
E |
take()
检索并删除此队列的头,如有必要,等待元素可用。
|
Object[] |
toArray()
以适当的顺序返回一个包含此队列中所有元素的数组。
|
<T> T[] |
toArray(T[] a)
以适当的顺序返回包含此队列中所有元素的数组;
返回的数组的运行时类型是指定数组的运行时类型。
|
String |
toString()
返回此集合的字符串表示形式。
|
addAll, element, remove
containsAll, isEmpty, removeAll, retainAll
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addAll, containsAll, equals, hashCode, isEmpty, parallelStream, removeAll, removeIf, retainAll, stream
public ArrayBlockingQueue(int capacity)
ArrayBlockingQueue
。
capacity
- 这个队列的容量
IllegalArgumentException
- 如果
capacity < 1
public ArrayBlockingQueue(int capacity, boolean fair)
ArrayBlockingQueue
具有给定(固定)容量和指定访问策略。
capacity
- 这个队列的容量
fair
- 如果true
然后对插入或删除阻塞的线程进行队列访问,则按FIFO顺序处理;
如果false
访问顺序未指定。
IllegalArgumentException
- 如果
capacity < 1
public ArrayBlockingQueue(int capacity, boolean fair, Collection<? extends E> c)
ArrayBlockingQueue
具有给定(固定)容量,指定访问策略和最初包含给定集合中的元素,添加在收集迭代器的遍历顺序。
capacity
- 这个队列的容量
fair
- 如果true
然后对插入或删除阻塞的线程进行队列访问,则按FIFO顺序处理;
如果false
访问顺序是未指定的。
c
- 最初包含的元素的集合
IllegalArgumentException
- 如果
capacity
小于
c.size()
或小于1。
NullPointerException
- 如果指定的集合或其任何元素为空
public boolean add(E e)
true
并抛出
IllegalStateException
。
add
在界面
Collection<E>
add
在界面
BlockingQueue<E>
add
在界面
Queue<E>
add
在类别
AbstractQueue<E>
e
- 要添加的元素
true
(由
Collection.add(E)
指定 )
IllegalStateException
- 如果此队列已满
NullPointerException
- 如果指定的元素为空
public boolean offer(E e)
false
如果该队列已满,则返回true
。
该方法通常比方法add(E)
更为方便 ,只能通过抛出异常来插入元素。
offer
在界面
BlockingQueue<E>
offer
在接口
Queue<E>
e
- 要添加的元素
true
如果元素被添加到此队列,否则
false
NullPointerException
- 如果指定的元素为空
public void put(E e) throws InterruptedException
put
在界面
BlockingQueue<E>
e
- 要添加的元素
InterruptedException
- 如果在等待时中断
NullPointerException
- 如果指定的元素为空
public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException
offer
在界面
BlockingQueue<E>
e
- 要添加的元素
timeout
- 放弃之前等待多久,以
unit
为单位
unit
- a
TimeUnit
确定如何解释
timeout
参数
true
如果成功,或
false
如果在空间可用之前经过指定的等待时间
InterruptedException
- 如果在等待时中断
NullPointerException
- 如果指定的元素为空
public E take() throws InterruptedException
BlockingQueue
复制
take
在接口
BlockingQueue<E>
InterruptedException
- 如果等待中断
public E poll(long timeout, TimeUnit unit) throws InterruptedException
BlockingQueue
复制
poll
在界面
BlockingQueue<E>
timeout
- 放弃之前等待多久,以
unit
为单位
unit
- a
TimeUnit
确定如何解释
timeout
参数
null
如果在元素可用之前经过了指定的等待时间
InterruptedException
- 如果在等待时中断
public int size()
size
在接口
Collection<E>
size
在类别
AbstractCollection<E>
public int remainingCapacity()
size
。
请注意,您不能总是通过检查remainingCapacity
来判断插入元素是否会成功,因为可能是另一个线程即将插入或删除元素的情况。
remainingCapacity
在接口
BlockingQueue<E>
public boolean remove(Object o)
e
,使得o.equals(e)
,如果这个队列包含一个或多个这样的元素。
如果此队列包含指定的元素(或等效地,如果此队列作为调用的结果而更改),则返回true
。
基于循环阵列的队列中的内部元素的删除是本质上缓慢和破坏性的操作,所以只应在特殊情况下进行,理想情况下只有当队列被其他线程知道时才能访问。
remove
在界面
Collection<E>
remove
在界面
BlockingQueue<E>
remove
在
AbstractCollection<E>
o
- 要从此队列中删除的元素(如果存在)
true
如果此队列由于调用而更改
public boolean contains(Object o)
true
。
更正式地,返回true
当且仅当这个队列包含至少一个元素e
这样o.equals(e)
。
contains
在界面
Collection<E>
contains
在界面
BlockingQueue<E>
contains
在
AbstractCollection<E>
o
- 要检查此队列中的遏制的对象
true
如果此队列包含指定的元素
public Object[] toArray()
返回的数组将是“安全的”,因为该队列不保留对它的引用。 (换句话说,这个方法必须分配一个新的数组)。 因此,调用者可以自由地修改返回的数组。
此方法充当基于阵列和基于集合的API之间的桥梁。
toArray
在界面
Collection<E>
toArray
在
AbstractCollection<E>
public <T> T[] toArray(T[] a)
如果这个队列符合指定的数组空间(即阵列比这个队列更多的元素),则队列结束后的数组中的元素将被设置为null
。
像toArray()
方法一样,此方法充当基于数组和基于集合的API之间的桥梁。 此外,该方法允许精确地控制输出阵列的运行时类型,并且在某些情况下可以用于节省分配成本。
假设x
是一个已知只包含字符串的队列。 下面的代码可以被用来将该队列转储到一个新分配的阵列String
:
String[] y = x.toArray(new String[0]);
请注意, toArray(new Object[0])
的功能与toArray()
。
toArray
在接口
Collection<E>
toArray
在
AbstractCollection<E>
T
- 包含集合的数组的运行时类型
a
- 要存储队列的元素的阵列,如果它足够大;
否则,为此目的分配相同运行时类型的新数组
ArrayStoreException
- 如果指定数组的运行时类型不是此队列中每个元素的运行时类型的超类型
NullPointerException
- 如果指定的数组为空
public String toString()
AbstractCollection
复制
String.valueOf(Object)
。
toString
在类别
AbstractCollection<E>
public void clear()
clear
在界面
Collection<E>
clear
在
AbstractQueue<E>
public int drainTo(Collection<? super E> c)
BlockingQueue
复制
c
添加元素时遇到的c
可能会导致在抛出关联的异常时,元素既不在两个集合中,也可能不是两个集合。
尝试将队列排入自身会导致IllegalArgumentException
。
此外,如果在操作进行中修改了指定的集合,则此操作的行为是未定义的。
drainTo
在接口
BlockingQueue<E>
c
- 将元素传输到的集合
UnsupportedOperationException
- 如果指定集合不支持添加元素
ClassCastException
- 如果此队列的元素的类阻止将其添加到指定的集合
NullPointerException
- 如果指定的集合为空
IllegalArgumentException
- 如果指定的集合是此队列,或该队列的某个元素的某些属性阻止将其添加到指定的集合
public int drainTo(Collection<? super E> c, int maxElements)
BlockingQueue
复制
c
添加元素时遇到的c
可能会导致元素在抛出关联的异常时既不在两个集合中,也可能不是两个集合。
尝试将队列排入自身会导致IllegalArgumentException
。
此外,如果在操作进行中修改了指定的集合,则此操作的行为是未定义的。
drainTo
在界面
BlockingQueue<E>
c
- 将元素传输到的集合
maxElements
- 要传输的元素的最大数量
UnsupportedOperationException
- 如果指定集合不支持添加元素
ClassCastException
- 如果此队列的元素的类阻止将其添加到指定的集合
NullPointerException
- 如果指定的集合为空
IllegalArgumentException
- 如果指定的集合是此队列,或此队列的某个元素的某些属性会阻止将其添加到指定的集合
public Iterator<E> iterator()
iterator
在界面
Iterable<E>
iterator
在界面
Collection<E>
iterator
在类别
AbstractCollection<E>
public Spliterator<E> spliterator()
Spliterator
。
返回的拼接器是weakly consistent 。
该Spliterator
报告Spliterator.CONCURRENT
, Spliterator.ORDERED
和Spliterator.NONNULL
。
spliterator
在接口
Iterable<E>
spliterator
在界面
Collection<E>
Spliterator
实现
trySplit
以允许有限的并行性。
Spliterator
在这个队列中的元素