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