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

Class GridAtomicCacheQueueImpl<T>

java.lang.Object

java.util.AbstractCollection<T>

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

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

All Implemented Interfaces:

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

public class GridAtomicCacheQueueImpl<T>
extends GridCacheQueueAdapter<T>

GridCacheQueue implementation using atomic cache.

Nested Class Summary

Nested classes/interfaces inherited from class org.gridgain.grid.kernal.processors.cache.datastructures.GridCacheQueueAdapter

GridCacheQueueAdapter.AddClosure, GridCacheQueueAdapter.ClearClosure, GridCacheQueueAdapter.PollClosure, GridCacheQueueAdapter.RemoveClosure

Field Summary

Fields inherited from class org.gridgain.grid.kernal.processors.cache.datastructures.GridCacheQueueAdapter

cache, cctx, id, log, MAX_UPDATE_RETRIES, QUEUE_REMOVED_IDX, queueKey, queueName, RETRY_DELAY

Constructor Summary

Constructors

Constructor and Description
GridAtomicCacheQueueImpl(String queueName, GridCacheQueueHeader hdr, GridCacheContext<?,?> cctx)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	addAll(Collection<? extends T> items)
boolean	offer(T item)
T	poll()
protected void	removeItem(long rmvIdx) Removes item with given index from queue.

Methods inherited from class org.gridgain.grid.kernal.processors.cache.datastructures.GridCacheQueueAdapter

add, bounded, capacity, checkRemoved, checkRemoved, clear, collocated, drainTo, drainTo, element, equals, hashCode, itemKey, iterator, name, offer, peek, poll, put, remainingCapacity, remove, removed, size, take, toString

Methods inherited from class java.util.AbstractCollection

clear, contains, containsAll, isEmpty, remove, removeAll, retainAll, toArray, toArray

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.gridgain.grid.cache.datastructures.GridCacheQueue

clear, contains, containsAll, isEmpty, remove, removeAll, retainAll, toArray, toArray

Constructor Detail

GridAtomicCacheQueueImpl

public GridAtomicCacheQueueImpl(String queueName,
                        GridCacheQueueHeader hdr,
                        GridCacheContext<?,?> cctx)

Parameters:

queueName - Queue name.

hdr - Queue header.

cctx - Cache context.

Method Detail

offer

public boolean offer(T item)
              throws GridRuntimeException

Throws:

GridRuntimeException

poll

@Nullable
public T poll()
       throws GridRuntimeException

Throws:

GridRuntimeException

addAll

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

Specified by:

addAll in interface Collection<T>

Specified by:

addAll in interface GridCacheQueue<T>

Overrides:

addAll in class AbstractCollection<T>

removeItem

protected void removeItem(long rmvIdx)
                   throws GridException

Removes item with given index from queue.

Specified by:

removeItem in class GridCacheQueueAdapter<T>

Parameters:

rmvIdx - Index of item to be removed.

Throws:

GridException - If failed.