Class StoredBlockingDeque<T>

java.lang.Object

dev.blackilykat.pmp.storage.Stored<BlockingDeque<T>>

dev.blackilykat.pmp.storage.StoredBlockingDeque<T>

public class StoredBlockingDeque<T>
extends Stored<BlockingDeque<T>>

BlockingDeque for use in storage designed to have at most 1 consuming thread.

Nested Class Summary

Nested classes/interfaces inherited from class Stored

Stored.Serializer

Field Summary

Fields inherited from class Stored

storage, type, value

Constructor Summary

Constructors

Constructor	Description
StoredBlockingDeque(Type type, Storage storage)

Method Summary

Modifier and Type	Method	Description
void	add(T t)	Equivalent to BlockingDeque.add(E)
T	blockingPeek()	Equivalent to peek(), but if the queue is empty blocks until a value is added.
BlockingDeque<T>	get()	Get the inner stored value.
T	peek()	Equivalent to BlockingDeque.peek()
void	take()	Equivalent to BlockingDeque.take()
List<T>	viewAll()	Get a safely iterable copy of the list of all values in this queue.

Methods inherited from class Stored

set

Methods inherited from class Object

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

Constructor Details

StoredBlockingDeque

public StoredBlockingDeque(Type type,
 Storage storage)

Method Details

get

public BlockingDeque<T> get()

Description copied from class: Stored

Get the inner stored value.

Overrides:

get in class Stored<BlockingDeque<T>>

blockingPeek

public T blockingPeek()
               throws InterruptedException

Equivalent to peek(), but if the queue is empty blocks until a value is added.

Throws:

InterruptedException

peek

public T peek()

Equivalent to BlockingDeque.peek()

add

public void add(T t)

Equivalent to BlockingDeque.add(E)

take

public void take()

Equivalent to BlockingDeque.take()

viewAll

public List<T> viewAll()

Get a safely iterable copy of the list of all values in this queue.