edu.rice.hj.experimental.actors

Class DeclarativeSelector<MessageType>

java.lang.Object

edu.rice.hj.experimental.actors.Selector<MessageType>

edu.rice.hj.experimental.actors.DeclarativeSelector<MessageType>

public abstract class DeclarativeSelector<MessageType>
extends Selector<MessageType>

Author:

Shams Imam (shams@rice.edu)

Field Summary

Fields inherited from class edu.rice.hj.experimental.actors.Selector

numClassifiers

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DeclarativeSelector(Class<? extends Enum<?>> enumClass)
protected	DeclarativeSelector(Class<? extends Enum<?>> enumClass, boolean pAlwaysSequentialBody)
protected	DeclarativeSelector(int numMailboxes)
protected	DeclarativeSelector(int numMailboxes, boolean pAlwaysSequentialBody, boolean pPriorityPolicy)

Method Summary

Modifier and Type	Method and Description
protected abstract void	doProcess(MessageType theMsg)
protected void	guard(Enum<?> mailboxName, java.util.function.Predicate<MessageType> guardExpr)
protected void	guard(int mailboxId, java.util.function.Predicate<MessageType> guardExpr)
protected void	onPreStart() Convenience: specify code to be executed before selector is started
protected void	process(MessageType theMsg) Callback allowing user to have custom behavior while processing messages.
protected abstract void	registerGuards()

Methods inherited from class edu.rice.hj.experimental.actors.Selector

disable, disable, disableAllExcept, disableAllExcept, enable, enable, enableAll, exit, handleThrowable, hasStarted, isEnabled, isEnabled, onPostExit, onPostStart, onPreExit, send, send, start, start, tryProcessMessage

Methods inherited from class java.lang.Object

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

Constructor Detail

DeclarativeSelector

protected DeclarativeSelector(Class<? extends Enum<?>> enumClass)

DeclarativeSelector

protected DeclarativeSelector(int numMailboxes)

DeclarativeSelector

protected DeclarativeSelector(int numMailboxes,
                              boolean pAlwaysSequentialBody,
                              boolean pPriorityPolicy)

DeclarativeSelector

protected DeclarativeSelector(Class<? extends Enum<?>> enumClass,
                              boolean pAlwaysSequentialBody)

Method Detail

onPreStart

protected void onPreStart()

Description copied from class: Selector

Convenience: specify code to be executed before selector is started

Overrides:

onPreStart in class Selector<MessageType>

registerGuards

protected abstract void registerGuards()

guard

protected final void guard(Enum<?> mailboxName,
                           java.util.function.Predicate<MessageType> guardExpr)

guard

protected final void guard(int mailboxId,
                           java.util.function.Predicate<MessageType> guardExpr)

process

protected final void process(MessageType theMsg)

Description copied from class: Selector

Callback allowing user to have custom behavior while processing messages.

Specified by:

process in class Selector<MessageType>

Parameters:

theMsg - message to process

doProcess

protected abstract void doProcess(MessageType theMsg)