Field Detail

• private static final int ACTIVE

• private static final int PASSIVE

• @java.lang.SuppressWarnings({"FieldMayBeFinal", "unused"}) // TODO: Eclipse requires this to be tagged as unused. private int active

  Indicates, whether there's an active thread handling a message inside the agent's body

• private static final java.util.concurrent.atomic.AtomicIntegerFieldUpdater<AsyncMessagingCore> activeUpdater

• private boolean fair

  Fair agents give up the thread after processing each message, non-fair agents keep a thread until their message queue is empty.

• private final MessageQueue queue

  Incoming messages

• private Pool threadPool

Constructor Detail

• protected AsyncMessagingCore(Pool threadPool)

Method Detail

• public final void attachToThreadPool(Pool threadPool)

  Sets a new thread pool to be used by the agent

  Parameters:

  threadPool - The thread pool to use

• protected boolean continueProcessingMessages()

  Informs about a new thread being assigned to process the next message

  Returns:

  True, if the calculation should proceed

• Pool getThreadPool()

• protected void handleMessage(java.lang.Object message)

• public boolean isFair()

  Retrieves the agent's fairness flag Fair agents give up the thread after processing each message, non-fair agents keep a thread until their message queue is empty. Non-fair agents tend to perform better than fair ones.

  Returns:

  True for fair agents, false for non-fair ones. Agents are non-fair by default.

• public void makeFair()

  Makes the agent fair. Agents are non-fair by default. Fair agents give up the thread after processing each message, non-fair agents keep a thread until their message queue is empty. Non-fair agents tend to perform better than fair ones.

• protected void registerError(java.lang.Throwable e)

• @java.lang.Override @java.lang.SuppressWarnings({"CatchGenericClass", "ThrowCaughtLocally", "OverlyBroadCatchBlock"}) public final void run()

  Handles a single message from the message queue

• void schedule()

  Schedules processing of a next message, if there are some and if there isn't an active thread handling a message at the moment

• public void store(java.lang.Object message)

  Adds the message to the agent\s message queue

  Parameters:

  message - A value or a closure

• public java.lang.Object sweepNextMessage()

  Removes the head of the message queue

  Returns:

  The head message, or null, if the message queue is empty

• @java.lang.SuppressWarnings({"NoopMethodInAbstractClass"}) protected void threadAssigned()

  Informs about the thread being removed from the task

• @java.lang.SuppressWarnings({"NoopMethodInAbstractClass"}) protected void threadUnassigned()

  Informs about a new thread being assigned to process the next message