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

GenericQueue()
Create an empty queue

Method Summary

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()

Methods inherited from class java.lang.Object

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

Constructor Detail

GenericQueue

public GenericQueue()

Create an empty queue

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()