public class SingletonQueue<T> extends Object
close()
the queue.
The queue is either empty (take()
calls will block) or full (calls will block
.A closed
queue will not block on any put
call but will silently ignore the value. Calling take()
on a
closed queue will always return the special end element.Constructor and Description |
---|
SingletonQueue(T eoq)
Creates a new queue with the specific End-Of-Queue element.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the queue causing all blocked threads to be unblocked.
|
T |
getEOQ()
Returns the special end of queue (EOQ) value.
|
boolean |
isEmpty() |
boolean |
isFull() |
void |
put(T x)
Puts a value to the queue waiting indefinitely if the queue is full.
|
T |
take()
Take a value from the queue waiting indefinitely if it is empty.
|
public SingletonQueue(T eoq)
public boolean isFull()
public boolean isEmpty()
public T getEOQ()
public void put(T x) throws InterruptedException
InterruptedException
public T take() throws InterruptedException
end element
.InterruptedException
public void close() throws InterruptedException
put(Object)
after this call
will be ignored.InterruptedException
Copyright © 2010-2016 Stardog Union. All Rights Reserved.