org.apache.qpid.util.concurrent
Class SynchQueue<E>
java.lang.Object
java.util.AbstractCollection<E>
java.util.AbstractQueue<E>
org.apache.qpid.util.concurrent.BatchSynchQueueBase<E>
org.apache.qpid.util.concurrent.SynchQueue<E>
- All Implemented Interfaces:
- Iterable<E>, Collection<E>, BlockingQueue<E>, Queue<E>, BatchSynchQueue<E>
public class SynchQueue<E>
- extends BatchSynchQueueBase<E>
SynchQueue completes the BatchSynchQueueBase
abstract class by providing an implementation of the underlying
queue as a linked list. This uses FIFO ordering for the queue and allows the queue to grow to accomodate more
elements as needed.
CRC Card
Responsibilities | Collaborations
|
---|
Provide linked list FIFO queue to create a batch synched queue around.
|
Method Summary |
protected
|
createQueue()
Returns an empty queue, implemented as a linked list. |
Methods inherited from class org.apache.qpid.util.concurrent.BatchSynchQueueBase |
drainTo, drainTo, drainTo, drainTo, extract, getBufferCapacity, insert, iterator, offer, offer, peek, peekAtBufferHead, poll, poll, put, remainingCapacity, size, take, tryPut |
SynchQueue
public SynchQueue()
createQueue
protected <T> Queue<T> createQueue()
- Returns an empty queue, implemented as a linked list.
- Specified by:
createQueue
in class BatchSynchQueueBase<E>
- Returns:
- An empty queue, implemented as a linked list.
Licensed to the Apache Software Foundation