public class GenericQueue
extends java.lang.Object
Constructor | Description |
---|---|
GenericQueue() |
Create an empty queue
|
Modifier and Type | Method | 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 flush()
public void close()
public void put(java.lang.Object o)
o
- Object to insert in the queuepublic 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 java.lang.Object tryGet()
public int getCount()