T
- the type of state hold by the agentpublic class RemoteAgent<T> extends AgentCore implements RemoteSerialized
Modifier and Type | Field and Description |
---|---|
private AgentClosureExecutionPolicy |
executionPolicy |
private RemoteHost |
remoteHost |
currentThread
serialHandle
Constructor and Description |
---|
RemoteAgent(RemoteHost remoteHost) |
Modifier and Type | Method and Description |
---|---|
T |
getVal() |
void |
handleMessage(java.lang.Object message)
Dynamically dispatches the method call
|
void |
setExecutionPolicy(AgentClosureExecutionPolicy executionPolicy) |
attachToThreadPool, call, getErrors, hasErrors, isFair, leftShift, makeFair, send, setPGroup
createRemoteHandle, getOrCreateSerialHandle, getRemoteClass, writeReplace
private final RemoteHost remoteHost
private AgentClosureExecutionPolicy executionPolicy
public RemoteAgent(RemoteHost remoteHost)
public void setExecutionPolicy(AgentClosureExecutionPolicy executionPolicy)
public void handleMessage(java.lang.Object message)
AgentCore
handleMessage
in class AgentCore
message
- A value or a closurepublic T getVal() throws java.lang.InterruptedException
java.lang.InterruptedException