fi.jumi.actors.queue

Class MessageQueue<T>

java.lang.Object

fi.jumi.actors.queue.MessageQueue<T>

All Implemented Interfaces:

MessageReceiver<T>, MessageSender<T>

@ThreadSafe
public class MessageQueue<T>
extends Object
implements MessageSender<T>, MessageReceiver<T>

Asynchronous unbounded queue for message passing.

Constructor Summary

Constructors

Constructor and Description
MessageQueue()

Method Summary

Methods

Modifier and Type	Method and Description
T	poll()
void	send(T message)
T	take()

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageQueue

public MessageQueue()

Method Detail

send

public void send(T message)

Specified by:

send in interface MessageSender<T>

take

public T take()
       throws InterruptedException

Specified by:

take in interface MessageReceiver<T>

Throws:

InterruptedException

poll

public T poll()

Specified by:

poll in interface MessageReceiver<T>