public class GenericQueue
extends java.lang.Object
Constructor and Description |
---|
GenericQueue()
Create an empty queue
|
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
flush()
Clear a queue
|
java.lang.Object |
get()
Retrieve an object from the head of the queue, or block until one
arrives.
|
java.lang.Object |
get(long timeout)
Retrieve an object from the head of the queue, blocking until one arrives
or until timeout occurs.
|
int |
getCount() |
void |
put(java.lang.Object o)
Add an object to the tail of the queue.
|
java.lang.Object |
tryGet() |
public void close()
public void flush()
public java.lang.Object get()
public java.lang.Object get(long timeout) throws java.lang.InterruptedException
timeout
- Maximum time to block on queue, in ms. Use 0 to poll the
queue.java.lang.InterruptedException
- if the operation times out.public int getCount()
public void put(java.lang.Object o)
o
- Object to insert in the queuepublic java.lang.Object tryGet()