Package tools.refinery.interpreter.rete.network.communication.timely

Class TimelyCommunicationGroup

java.lang.Object

tools.refinery.interpreter.rete.network.communication.CommunicationGroup

tools.refinery.interpreter.rete.network.communication.timely.TimelyCommunicationGroup

All Implemented Interfaces:

Comparable<CommunicationGroup>

public class TimelyCommunicationGroup
extends CommunicationGroup

A timely communication group implementation. TimelyMailboxes and

invalid reference

LazyFoldingNode

s are ordered in the increasing order of timestamps.

Since:

2.3

Field Summary

Fields inherited from class tools.refinery.interpreter.rete.network.communication.CommunicationGroup

identifier, isEnqueued, representative, tracker, UNSUPPORTED_MESSAGE_KIND

Constructor Summary

Constructors

Constructor	Description
TimelyCommunicationGroup(TimelyCommunicationTracker tracker, Node representative, int identifier, boolean isSingleton)

Method Summary

Modifier and Type	Method	Description
void	deliverMessages()
Map<MessageSelector,Collection<Mailbox>>	getMailboxes()
boolean	isEmpty()
boolean	isRecursive()
void	notifyHasMessage(Mailbox mailbox, MessageSelector kind)
void	notifyLostAllMessages(Mailbox mailbox, MessageSelector kind)
void	setComparatorAndReorderMailboxes(Comparator<Node> nodeComparator)	Sets the Comparator to be used to order the Mailboxes at a given Timestamp in the mailbox queue.

Methods inherited from class tools.refinery.interpreter.rete.network.communication.CommunicationGroup

compareTo, equals, getRepresentative, hashCode, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

TimelyCommunicationGroup

public TimelyCommunicationGroup(TimelyCommunicationTracker tracker,
 Node representative,
 int identifier,
 boolean isSingleton)

Method Details

setComparatorAndReorderMailboxes

public void setComparatorAndReorderMailboxes(Comparator<Node> nodeComparator)

Sets the Comparator to be used to order the Mailboxes at a given Timestamp in the mailbox queue. Additionally, reorders already queued Mailboxes to reflect the new comparator. The comparator may be null, in this case, no set ordering will be enforced among the Mailboxes.

deliverMessages

public void deliverMessages()

Specified by:

deliverMessages in class CommunicationGroup

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in class CommunicationGroup

notifyHasMessage

public void notifyHasMessage(Mailbox mailbox,
 MessageSelector kind)

Specified by:

notifyHasMessage in class CommunicationGroup

notifyLostAllMessages

public void notifyLostAllMessages(Mailbox mailbox,
 MessageSelector kind)

Specified by:

notifyLostAllMessages in class CommunicationGroup

getMailboxes

public Map<MessageSelector,Collection<Mailbox>> getMailboxes()

Specified by:

getMailboxes in class CommunicationGroup

isRecursive

public boolean isRecursive()

Specified by:

isRecursive in class CommunicationGroup