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