This project has retired. For details please refer to its Attic page.

org.apache.excalibur.event.impl
Class FixedSizeQueue

java.lang.Object
  org.apache.excalibur.event.impl.AbstractQueue
      org.apache.excalibur.event.impl.FixedSizeQueue

All Implemented Interfaces:

Queue, Sink, Source

Deprecated. Use the DefaultQueue as it properly supports the EnqueuePredicates

public final class FixedSizeQueue

extends AbstractQueue

An implementation of the Queue that has a fixed size. Once the maximum number of elements are set, this Queue cannot be changed.

Author:

Avalon Development Team

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

java.lang.Object	dequeue() Deprecated. Dequeues the next element, or null if there is nothing left on the queue or in case of a timeout while attempting to obtain the mutex
java.lang.Object[]	dequeue(int numElements) Deprecated. Dequeues at most num available elements.
java.lang.Object[]	dequeueAll() Deprecated. Dequeues all available elements.
void	enqueue(java.lang.Object element) Deprecated. Enqueues the given element onto the Sink.
void	enqueue(java.lang.Object[] elements) Deprecated. Given an array of elements, atomically enqueues all of the elements in the array.
int	maxSize() Deprecated. Default maxSize to -1 which is unbounded
PreparedEnqueue	prepareEnqueue(java.lang.Object[] elements) Deprecated. Support for transactional enqueue.
int	size() Deprecated. Returns the number of elements waiting in this Source.
boolean	tryEnqueue(java.lang.Object element) Deprecated. Tries to enqueue an event, but instead of throwing exceptions, it returns a boolean value of whether the attempt was successful.

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

m_reserve

protected int m_reserve

Deprecated.

Constructor Detail

FixedSizeQueue

public FixedSizeQueue(int size)

Deprecated.

Create a FixedSizedQueue with the specified maximum size. The maximum size must be 1 or more.

Parameters:

size - The maximum number of events the Queue can handle

Method Detail

size

public int size()

Deprecated.

Description copied from interface: Source

Returns the number of elements waiting in this Source.

Returns:

the number of elements in the Source

maxSize

public int maxSize()

Deprecated.

Description copied from class: AbstractQueue

Default maxSize to -1 which is unbounded

Specified by:

maxSize in interface Sink

Overrides:

maxSize in class AbstractQueue

Returns:

the maximum number of elements

prepareEnqueue

public PreparedEnqueue prepareEnqueue(java.lang.Object[] elements)
                               throws SinkException

Deprecated.

Description copied from interface: Sink

Support for transactional enqueue.

This method allows a client to provisionally enqueue a number of elements onto the queue, and then later commit the enqueue (with a commitEnqueue call), or abort (with an abortEnqueue call). This mechanism can be used to perform "split-phase" enqueues, where a client first enqueues a set of elements on the queue and then performs some work to "fill in" those elements before performing a commit. This can also be used to perform multi-queue transactional enqueue operations, with an "all-or-nothing" strategy for enqueueing events on multiple Sinks.

This method would generally be used in the following manner:

   PreparedEnqueue enqueue = sink.prepareEnqueue(someElements);
   if (canCommit) {
     enqueue.commit();
   } else {
     enqueue.abort();
   }
 

Note that this method does not protect against "dangling prepares" -- that is, a prepare without an associated commit or abort operation. This method should be used with care. In particular, be sure that all code paths (such as exceptions) after a prepare include either a commit or an abort.

Parameters:

elements - The element array to provisionally enqueue

Returns:

A PreparedEnqueue that may be used to commit or abort the provisional enqueue

Throws:

SinkException

See Also:

PreparedEnqueue

tryEnqueue

public boolean tryEnqueue(java.lang.Object element)

Deprecated.

Description copied from interface: Sink

Tries to enqueue an event, but instead of throwing exceptions, it returns a boolean value of whether the attempt was successful.

Parameters:

element - The element to attempt to enqueue

Returns:

true if successful, false if not.

enqueue

public void enqueue(java.lang.Object[] elements)
             throws SinkException

Deprecated.

Description copied from interface: Sink

Given an array of elements, atomically enqueues all of the elements in the array. This guarantees that no other thread can interleave its own elements with those being inserted from this array. The implementation must enqueue all of the elements or none of them; if a SinkFullException or SinkClosedException is thrown, none of the elements will have been enqueued.

Parameters:

elements - The element array to enqueue

Throws:

SinkException

enqueue

public void enqueue(java.lang.Object element)
             throws SinkException

Deprecated.

Description copied from interface: Sink

Enqueues the given element onto the Sink.

Parameters:

element - The elements to enqueue

Throws:

SinkException

dequeue

public java.lang.Object[] dequeue(int numElements)

Deprecated.

Description copied from interface: Source

Dequeues at most num available elements. Returns a zero-sized array in case of a timeout while attempting to obtain the mutex or if there is nothing left on the Source.

Parameters:

numElements - The maximum number of elements to dequeue

Returns:

At most num elements from the Source

dequeueAll

public java.lang.Object[] dequeueAll()

Deprecated.

Description copied from interface: Source

Dequeues all available elements. Returns a zero-sized array in case of a timeout while attempting to obtain the mutex or if there is nothing left on the Source.

Returns:

all pending elements on the Source

dequeue

public java.lang.Object dequeue()

Deprecated.

Description copied from interface: Source

Dequeues the next element, or null if there is nothing left on the queue or in case of a timeout while attempting to obtain the mutex

Returns:

the next queue element on the Source