E
- public abstract class ConcurrentArrayBlockingQueue<E> extends ConcurrentArrayQueue<E> implements BlockingQueue<E>
ConcurrentArrayQueue
.Modifier and Type | Class and Description |
---|---|
static class |
ConcurrentArrayBlockingQueue.Bounded<E>
A bounded, blocking version of
ConcurrentArrayQueue . |
static class |
ConcurrentArrayBlockingQueue.Unbounded<E>
An unbounded, blocking version of
ConcurrentArrayQueue . |
ConcurrentArrayQueue.Block<E>
DEFAULT_BLOCK_SIZE, REMOVED_ELEMENT
Constructor and Description |
---|
ConcurrentArrayBlockingQueue(int blockSize) |
Modifier and Type | Method and Description |
---|---|
protected abstract int |
decrementAndGetSize() |
int |
drainTo(Collection<? super E> c) |
int |
drainTo(Collection<? super E> c,
int maxElements) |
E |
poll() |
E |
poll(long timeout,
TimeUnit unit) |
boolean |
remove(Object o) |
protected void |
signalConsumer() |
E |
take() |
casHeadBlock, casTailBlock, getBlockCount, getBlockSize, getHeadBlock, getTailBlock, iterator, newBlock, offer, peek, removeAll, retainAll, size
contains, containsAll, isEmpty, toArray, toArray, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
add, contains, offer, offer, put, remainingCapacity
public E poll()
public boolean remove(Object o)
remove
in interface Collection<E>
remove
in interface BlockingQueue<E>
remove
in class ConcurrentArrayQueue<E>
protected abstract int decrementAndGetSize()
protected void signalConsumer()
public E take() throws InterruptedException
take
in interface BlockingQueue<E>
InterruptedException
public E poll(long timeout, TimeUnit unit) throws InterruptedException
poll
in interface BlockingQueue<E>
InterruptedException
public int drainTo(Collection<? super E> c)
drainTo
in interface BlockingQueue<E>
public int drainTo(Collection<? super E> c, int maxElements)
drainTo
in interface BlockingQueue<E>
Copyright © 1995-2013 Mort Bay Consulting. All Rights Reserved.