Package tools.refinery.interpreter.rete.network.mailbox.timeless

Class AbstractUpdateSplittingMailbox<IndexerType extends MessageIndexer,ReceiverType extends Receiver>

java.lang.Object

tools.refinery.interpreter.rete.network.mailbox.timeless.AbstractUpdateSplittingMailbox<IndexerType,ReceiverType>

All Implemented Interfaces:

Clearable, IGroupable, Mailbox

Direct Known Subclasses:

PosetAwareMailbox, UpdateSplittingMailbox

public abstract class AbstractUpdateSplittingMailbox<IndexerType extends MessageIndexer,ReceiverType extends Receiver>
extends Object
implements Mailbox

An abstract mailbox implementation that is capable of splitting update messages based on some form of monotonicity (anti-monotone and monotone). The monotonicity is either defined by the less or equal operator of a poset or, it can be the standard subset ordering among sets of tuples.

Since:

2.0

Field Summary

Fields

Modifier and Type	Field	Description
protected IndexerType	antiMonotoneBuffer
protected IndexerType	antiMonotoneQueue
protected final ReteContainer	container
protected boolean	deliveringAntiMonotone
protected boolean	deliveringMonotone
protected CommunicationGroup	group
protected IndexerType	monotoneBuffer
protected IndexerType	monotoneQueue
protected final ReceiverType	receiver

Constructor Summary

Constructors

Constructor	Description
AbstractUpdateSplittingMailbox(ReceiverType receiver, ReteContainer container, MessageIndexerFactory<IndexerType> factory)

Method Summary

Modifier and Type	Method	Description
void	clear()
protected IndexerType	getActiveAntiMonotoneQueue()
protected IndexerType	getActiveMonotoneQueue()
CommunicationGroup	getCurrentGroup()	Returns the CommunicationGroup of the receiver of this mailbox.
ReceiverType	getReceiver()	Returns the Receiver of this mailbox.
boolean	isEmpty()	Returns true if this mailbox is empty.
void	setCurrentGroup(CommunicationGroup group)	Sets the CommunicationGroup that the receiver of this mailbox is associated with.
protected void	swapAndClearAntiMonotone()
protected void	swapAndClearMonotone()

Methods inherited from class java.lang.Object

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

Methods inherited from interface tools.refinery.interpreter.rete.network.mailbox.Mailbox

deliverAll, postMessage

Field Details

monotoneQueue

protected IndexerType extends MessageIndexer monotoneQueue

antiMonotoneQueue

protected IndexerType extends MessageIndexer antiMonotoneQueue

monotoneBuffer

protected IndexerType extends MessageIndexer monotoneBuffer

antiMonotoneBuffer

protected IndexerType extends MessageIndexer antiMonotoneBuffer

deliveringMonotone

protected boolean deliveringMonotone

deliveringAntiMonotone

protected boolean deliveringAntiMonotone

receiver

protected final ReceiverType extends Receiver receiver

container

protected final ReteContainer container

group

protected CommunicationGroup group

Constructor Details

AbstractUpdateSplittingMailbox

public AbstractUpdateSplittingMailbox(ReceiverType receiver,
 ReteContainer container,
 MessageIndexerFactory<IndexerType> factory)

Method Details

swapAndClearMonotone

protected void swapAndClearMonotone()

swapAndClearAntiMonotone

protected void swapAndClearAntiMonotone()

getActiveMonotoneQueue

protected IndexerType getActiveMonotoneQueue()

getActiveAntiMonotoneQueue

protected IndexerType getActiveAntiMonotoneQueue()

getReceiver

public ReceiverType getReceiver()

Description copied from interface: Mailbox

Returns the Receiver of this mailbox.

Specified by:

getReceiver in interface Mailbox

Returns:

the receiver

clear

public void clear()

Specified by:

clear in interface Clearable

isEmpty

public boolean isEmpty()

Description copied from interface: Mailbox

Returns true if this mailbox is empty.

Specified by:

isEmpty in interface Mailbox

Returns:

getCurrentGroup

public CommunicationGroup getCurrentGroup()

Description copied from interface: Mailbox

Returns the CommunicationGroup of the receiver of this mailbox.

Specified by:

getCurrentGroup in interface IGroupable

Specified by:

getCurrentGroup in interface Mailbox

Returns:

the communication group

setCurrentGroup

public void setCurrentGroup(CommunicationGroup group)

Description copied from interface: Mailbox

Sets the CommunicationGroup that the receiver of this mailbox is associated with.

Specified by:

setCurrentGroup in interface IGroupable

Specified by:

setCurrentGroup in interface Mailbox

Parameters:

group - the communication group