org.gridgain.grid.kernal.processors.cache.datastructures

Class GridCacheQueueProxy<T>

java.lang.Object

org.gridgain.grid.kernal.processors.cache.datastructures.GridCacheQueueProxy<T>

All Implemented Interfaces:

Externalizable, Serializable, Iterable<T>, Collection<T>, BlockingQueue<T>, Queue<T>, GridCacheQueue<T>

public class GridCacheQueueProxy<T>
extends Object
implements GridCacheQueue<T>, Externalizable

Cache queue proxy.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GridCacheQueueProxy() Required by Externalizable.
GridCacheQueueProxy(GridCacheContext cctx, GridCacheQueueAdapter<T> delegate)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	add(T item)
boolean	addAll(Collection<? extends T> items)
boolean	bounded() Returns true if this queue is bounded.
int	capacity() Gets maximum number of elements of the queue.
void	clear()
void	clear(int batchSize) Removes all of the elements from this queue.
boolean	collocated() Returns true if this queue can be kept on the one node only.
boolean	contains(Object item)
boolean	containsAll(Collection<?> items)
GridCacheQueueAdapter<T>	delegate()
int	drainTo(Collection<? super T> c)
int	drainTo(Collection<? super T> c, int maxElements)
T	element()
boolean	equals(Object o)
int	hashCode()
boolean	isEmpty()
Iterator<T>	iterator()
String	name() Gets queue name.
boolean	offer(T item)
boolean	offer(T item, long timeout, TimeUnit unit)
T	peek()
T	poll()
T	poll(long timeout, TimeUnit unit)
void	put(T item)
void	readExternal(ObjectInput in)
protected Object	readResolve() Reconstructs object on demarshalling.
int	remainingCapacity()
T	remove()
boolean	remove(Object item)
boolean	removeAll(Collection<?> items)
boolean	removed() Gets status of queue.
boolean	retainAll(Collection<?> items)
int	size()
T	take()
Object[]	toArray()
<T1> T1[]	toArray(T1[] a)
String	toString()
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

GridCacheQueueProxy

public GridCacheQueueProxy()

Required by Externalizable.

GridCacheQueueProxy

public GridCacheQueueProxy(GridCacheContext cctx,
                   GridCacheQueueAdapter<T> delegate)

Parameters:

cctx - Cache context.

delegate - Delegate queue.

Method Detail

delegate

public GridCacheQueueAdapter<T> delegate()

Returns:

Delegate queue.

add

public boolean add(T item)

Specified by:

add in interface Collection<T>

Specified by:

add in interface BlockingQueue<T>

Specified by:

add in interface Queue<T>

Specified by:

add in interface GridCacheQueue<T>

offer

public boolean offer(T item)

Specified by:

offer in interface BlockingQueue<T>

Specified by:

offer in interface Queue<T>

Specified by:

offer in interface GridCacheQueue<T>

addAll

public boolean addAll(Collection<? extends T> items)

Specified by:

addAll in interface Collection<T>

Specified by:

addAll in interface GridCacheQueue<T>

contains

public boolean contains(Object item)

Specified by:

contains in interface Collection<T>

Specified by:

contains in interface BlockingQueue<T>

Specified by:

contains in interface GridCacheQueue<T>

containsAll

public boolean containsAll(Collection<?> items)

Specified by:

containsAll in interface Collection<T>

Specified by:

containsAll in interface GridCacheQueue<T>

clear

public void clear()

Specified by:

clear in interface Collection<T>

Specified by:

clear in interface GridCacheQueue<T>

remove

public boolean remove(Object item)

Specified by:

remove in interface Collection<T>

Specified by:

remove in interface BlockingQueue<T>

Specified by:

remove in interface GridCacheQueue<T>

removeAll

public boolean removeAll(Collection<?> items)

Specified by:

removeAll in interface Collection<T>

Specified by:

removeAll in interface GridCacheQueue<T>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface Collection<T>

Specified by:

isEmpty in interface GridCacheQueue<T>

iterator

public Iterator<T> iterator()

Specified by:

iterator in interface Iterable<T>

Specified by:

iterator in interface Collection<T>

Specified by:

iterator in interface GridCacheQueue<T>

toArray

public Object[] toArray()

Specified by:

toArray in interface Collection<T>

Specified by:

toArray in interface GridCacheQueue<T>

toArray

public <T1> T1[] toArray(T1[] a)

Specified by:

toArray in interface Collection<T>

Specified by:

toArray in interface GridCacheQueue<T>

retainAll

public boolean retainAll(Collection<?> items)

Specified by:

retainAll in interface Collection<T>

Specified by:

retainAll in interface GridCacheQueue<T>

size

public int size()

Specified by:

size in interface Collection<T>

Specified by:

size in interface GridCacheQueue<T>

poll

@Nullable
public T poll()

Specified by:

poll in interface Queue<T>

Specified by:

poll in interface GridCacheQueue<T>

peek

@Nullable
public T peek()

Specified by:

peek in interface Queue<T>

Specified by:

peek in interface GridCacheQueue<T>

clear

public void clear(int batchSize)

Removes all of the elements from this queue. Method is used in massive queues with huge numbers of elements.

Specified by:

clear in interface GridCacheQueue<T>

Parameters:

batchSize - Batch size.

remainingCapacity

public int remainingCapacity()

Specified by:

remainingCapacity in interface BlockingQueue<T>

drainTo

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

Specified by:

drainTo in interface BlockingQueue<T>

drainTo

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

Specified by:

drainTo in interface BlockingQueue<T>

remove

public T remove()

Specified by:

remove in interface Queue<T>

element

public T element()

Specified by:

element in interface Queue<T>

put

public void put(T item)

Specified by:

put in interface BlockingQueue<T>

Specified by:

put in interface GridCacheQueue<T>

offer

public boolean offer(T item,
            long timeout,
            TimeUnit unit)

Specified by:

offer in interface BlockingQueue<T>

Specified by:

offer in interface GridCacheQueue<T>

take

@Nullable
public T take()

Specified by:

take in interface BlockingQueue<T>

Specified by:

take in interface GridCacheQueue<T>

poll

@Nullable
public T poll(long timeout,
              TimeUnit unit)

Specified by:

poll in interface BlockingQueue<T>

Specified by:

poll in interface GridCacheQueue<T>

name

public String name()

Gets queue name.

Specified by:

name in interface GridCacheQueue<T>

Returns:

Queue name.

capacity

public int capacity()
             throws GridException

Gets maximum number of elements of the queue.

Specified by:

capacity in interface GridCacheQueue<T>

Returns:

Maximum number of elements. If queue is unbounded Integer.MAX_SIZE will return.

Throws:

GridException - If operation failed.

bounded

public boolean bounded()
                throws GridException

Returns true if this queue is bounded.

Specified by:

bounded in interface GridCacheQueue<T>

Returns:

true if this queue is bounded.

Throws:

GridException - If operation failed.

collocated

public boolean collocated()
                   throws GridException

Returns true if this queue can be kept on the one node only. Returns false if this queue can be kept on the many nodes.

Specified by:

collocated in interface GridCacheQueue<T>

Returns:

true if this queue is in collocated mode false otherwise.

Throws:

GridException - If operation failed.

removed

public boolean removed()

Gets status of queue.

Specified by:

removed in interface GridCacheQueue<T>

Returns:

true if queue was removed from cache false otherwise.

hashCode

public int hashCode()

Specified by:

hashCode in interface Collection<T>

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Specified by:

equals in interface Collection<T>

Overrides:

equals in class Object

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

readResolve

protected Object readResolve()
                      throws ObjectStreamException

Reconstructs object on demarshalling.

Returns:

Reconstructed object.

Throws:

ObjectStreamException - Thrown in case of demarshalling error.

toString

public String toString()

Overrides:

toString in class Object