org.aredis.util.concurrent

Class SynchronizedStack<E>

java.lang.Object

org.aredis.util.concurrent.SynchronizedStack<E>

All Implemented Interfaces:

Serializable

public class SynchronizedStack<E>
extends Object
implements Serializable

A simple array based synchronized stack implementing a subset of methods in BlockingDeque. This is for use in AsyncObjectPool and should be faster than LinkedBlockingDeque in size checks and dequeuing on an empty Q which is expected in a busy pool.

Author:

suresh

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SynchronizedStack(int capacity) Creates a Synchronized Stack.

Method Summary

Methods

Modifier and Type	Method and Description
int	drainTo(Collection<? super E> c)
int	drainTo(Collection<? super E> c, int maxElements)
int	getCapacity() Gets max capacity of this stack was created with which is the length of the underlying array.
boolean	offerFirst(E item)
E	pollFirst()
boolean	setCapacity(int newCapacity) Sets the capacity of the stack to the new value if the current count is not greater than the new capacity.
int	size()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SynchronizedStack

public SynchronizedStack(int capacity)

Creates a Synchronized Stack.

Parameters:

capacity - Max elements in the stack

Method Detail

offerFirst

public boolean offerFirst(E item)

See Also:

BlockingDeque.offerFirst(Object)

pollFirst

public E pollFirst()

See Also:

Deque.pollFirst()

drainTo

public int drainTo(Collection<? super E> c,
          int maxElements)

See Also:

BlockingQueue.drainTo(Collection, int)

drainTo

public int drainTo(Collection<? super E> c)

See Also:

BlockingQueue.drainTo(Collection)

size

public int size()

See Also:

BlockingDeque.size()

getCapacity

public int getCapacity()

Gets max capacity of this stack was created with which is the length of the underlying array.

Returns:

capcity of the stack

setCapacity

public boolean setCapacity(int newCapacity)

Sets the capacity of the stack to the new value if the current count is not greater than the new capacity.

Parameters:

newCapacity - New Capacity

Returns:

true if successful in updating the capacity, false if capacity is unchanged