com.github.rholder.moar.concurrent

Class StrategicBlockingQueue<E>

java.lang.Object

com.github.rholder.moar.concurrent.WrappedBlockingQueue<E>

com.github.rholder.moar.concurrent.StrategicBlockingQueue<E>

Type Parameters:

E - the type of elements held in this collection

All Implemented Interfaces:

java.lang.Iterable<E>, java.util.Collection<E>, java.util.concurrent.BlockingQueue<E>, java.util.Queue<E>

public class StrategicBlockingQueue<E>
extends WrappedBlockingQueue<E>

A StrategicBlockingQueue wraps a standard BlockingQueue, providing a QueueingStrategy for performing actions before and after adding and removing items from the wrapped queue.

Constructor Summary

Constructors

Constructor and Description
StrategicBlockingQueue(java.util.concurrent.BlockingQueue<E> blockingQueue, QueueingStrategy<E> queueingStrategy)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	add(E e)
E	poll()
E	poll(long timeout, java.util.concurrent.TimeUnit unit)
void	put(E e)
E	take()

Methods inherited from class com.github.rholder.moar.concurrent.WrappedBlockingQueue

addAll, clear, contains, containsAll, drainTo, drainTo, element, isEmpty, iterator, offer, offer, peek, remainingCapacity, remove, remove, removeAll, retainAll, size, toArray, toArray

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Collection

equals, hashCode

Constructor Detail

StrategicBlockingQueue

public StrategicBlockingQueue(java.util.concurrent.BlockingQueue<E> blockingQueue,
                      QueueingStrategy<E> queueingStrategy)

Method Detail

put

public void put(E e)
         throws java.lang.InterruptedException

Specified by:

put in interface java.util.concurrent.BlockingQueue<E>

Overrides:

put in class WrappedBlockingQueue<E>

Throws:

java.lang.InterruptedException

add

public boolean add(E e)

Specified by:

add in interface java.util.Collection<E>

Specified by:

add in interface java.util.concurrent.BlockingQueue<E>

Specified by:

add in interface java.util.Queue<E>

Overrides:

add in class WrappedBlockingQueue<E>

take

public E take()
       throws java.lang.InterruptedException

Specified by:

take in interface java.util.concurrent.BlockingQueue<E>

Overrides:

take in class WrappedBlockingQueue<E>

Throws:

java.lang.InterruptedException

poll

public E poll(long timeout,
     java.util.concurrent.TimeUnit unit)
       throws java.lang.InterruptedException

Specified by:

poll in interface java.util.concurrent.BlockingQueue<E>

Overrides:

poll in class WrappedBlockingQueue<E>

Throws:

java.lang.InterruptedException

poll

public E poll()

Specified by:

poll in interface java.util.Queue<E>

Overrides:

poll in class WrappedBlockingQueue<E>