Package com.ericsson.otp.erlang
Class GenericQueue
- java.lang.Object
-
- com.ericsson.otp.erlang.GenericQueue
-
public class GenericQueue extends java.lang.Object
This class implements a generic FIFO queue. There is no upper bound on the length of the queue, items are linked.
-
-
Constructor Summary
Constructors Constructor Description GenericQueue()
Create an empty queue
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
void
flush()
Clear a queuejava.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()
-
-
-
Method Detail
-
flush
public void flush()
Clear a queue
-
close
public void close()
-
put
public void put(java.lang.Object o)
Add an object to the tail of the queue.- Parameters:
o
- Object to insert in the queue
-
get
public java.lang.Object get()
Retrieve an object from the head of the queue, or block until one arrives.- Returns:
- The object at the head of the queue.
-
get
public java.lang.Object get(long timeout) throws java.lang.InterruptedException
Retrieve an object from the head of the queue, blocking until one arrives or until timeout occurs.- Parameters:
timeout
- Maximum time to block on queue, in ms. Use 0 to poll the queue.- Returns:
- The object at the head of the queue, or null if none arrived in time.
- Throws:
java.lang.InterruptedException
- if the operation times out.
-
tryGet
public java.lang.Object tryGet()
-
getCount
public int getCount()
-
-