Modifiers | Name | Description |
---|---|---|
private AsyncMessagingCore |
core |
|
protected java.lang.Thread |
currentThread |
|
private java.util.List<java.lang.Throwable> |
errors |
Holds agent errors |
Fields inherited from class | Fields |
---|---|
class WithSerialId |
serialHandle, serialVersionUID |
Constructor and description |
---|
protected AgentCore
() |
Type | Name and description |
---|---|
void |
attachToThreadPool(Pool threadPool) Informs about the thread being removed from the task |
void |
call(java.lang.Object message) Adds the message to the agent\s message queue |
java.util.List<java.lang.Throwable> |
getErrors() Retrieves a list of exception thrown within the agent's body. |
void |
handleMessage(java.lang.Object message) Dynamically dispatches the method call |
boolean |
hasErrors() Indicates whether there have been exception thrown within the agent's body. |
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. |
void |
leftShift(java.lang.Object message) Adds the message to the agent\s message queue |
void |
makeFair() Makes the agent fair. |
void |
registerError(java.lang.Throwable e) Adds the exception to the list of thrown exceptions |
void |
send(java.lang.Object message) Adds the message to the agent\s message queue |
void |
setPGroup(PGroup pGroup) Sets an actor group to use for task scheduling |
Methods inherited from class | Name |
---|---|
class WithSerialId |
createRemoteHandle, getOrCreateSerialHandle, getRemoteClass, writeReplace |
class java.lang.Object |
java.lang.Object#wait(), java.lang.Object#wait(long, int), java.lang.Object#wait(long), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll() |
Holds agent errors
Informs about the thread being removed from the task
Adds the message to the agent\s message queue
message
- A value or a closureRetrieves a list of exception thrown within the agent's body. Clears the exception history
Dynamically dispatches the method call
message
- A value or a closureIndicates whether there have been exception thrown within the agent's body.
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.
Adds the message to the agent\s message queue
message
- A value or a closureMakes 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.
Adds the exception to the list of thrown exceptions
e
- The exception to storeAdds the message to the agent\s message queue
message
- A value or a closureSets an actor group to use for task scheduling
pGroup
- The pGroup to useCopyright © 2008–2014 Václav Pech. All Rights Reserved.