|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.apache.excalibur.event.impl.AbstractQueue
org.apache.excalibur.event.impl.FixedSizeQueue
public final class FixedSizeQueue
An implementation of the Queue that has a fixed size. Once
the maximum number of elements are set, this Queue cannot be
changed.
| Field Summary | |
|---|---|
protected int |
m_reserve
Deprecated. |
| Fields inherited from class org.apache.excalibur.event.impl.AbstractQueue |
|---|
EMPTY_ARRAY, m_interceptor, m_predicate, m_timeout |
| Fields inherited from interface org.apache.excalibur.event.Queue |
|---|
ROLE |
| Constructor Summary | |
|---|---|
FixedSizeQueue(int size)
Deprecated. Create a FixedSizedQueue with the specified maximum size. |
|
| Method Summary | |
|---|---|
Object |
dequeue()
Deprecated. |
Object[] |
dequeue(int numElements)
Deprecated. |
Object[] |
dequeueAll()
Deprecated. |
void |
enqueue(Object element)
Deprecated. |
void |
enqueue(Object[] elements)
Deprecated. |
int |
maxSize()
Deprecated. Default maxSize to -1 which is unbounded |
PreparedEnqueue |
prepareEnqueue(Object[] elements)
Deprecated. |
int |
size()
Deprecated. |
boolean |
tryEnqueue(Object element)
Deprecated. |
| Methods inherited from class org.apache.excalibur.event.impl.AbstractQueue |
|---|
block, canAccept, getDequeueInterceptor, getEnqueuePredicate, isFull, setDequeueInterceptor, setEnqueuePredicate, setTimeout |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Field Detail |
|---|
protected int m_reserve
| Constructor Detail |
|---|
public FixedSizeQueue(int size)
FixedSizedQueue with the specified maximum size.
The maximum size must be 1 or more.
size - The maximum number of events the Queue can handle| Method Detail |
|---|
public int size()
public int maxSize()
AbstractQueue
maxSize in interface SinkmaxSize in class AbstractQueue
public PreparedEnqueue prepareEnqueue(Object[] elements)
throws SinkException
SinkExceptionpublic boolean tryEnqueue(Object element)
public void enqueue(Object[] elements)
throws SinkException
SinkException
public void enqueue(Object element)
throws SinkException
SinkExceptionpublic Object[] dequeue(int numElements)
public Object[] dequeueAll()
public Object dequeue()
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||