Package | Description |
---|---|
groovyx.gpars.agent | |
groovyx.gpars.agent.remote | |
groovyx.gpars.remote.message |
This package holds message classes for the remote actors implementation.
|
Modifier and Type | Method and Description |
---|---|
java.lang.Class<RemoteAgent> |
Agent.getRemoteClass() |
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.ConcurrentMap<java.lang.String,DataflowVariable<RemoteAgent>> |
RemoteAgents.remoteAgents
Stores promises to remote instances of Agents.
|
Modifier and Type | Method and Description |
---|---|
Promise<RemoteAgent> |
RemoteAgents.get(java.lang.String host,
int port,
java.lang.String name)
Retrieves
Agent published under specified name on remote host. |
Modifier and Type | Method and Description |
---|---|
<T> SerialMsg |
AgentClosureExecutionPolicy.prepareGetValMessage(RemoteAgent<T> agent,
DataflowVariable<T> resultVariable) |
abstract SerialMsg |
AgentClosureExecutionPolicy.prepareMessage(RemoteAgent<?> agent,
java.lang.Object message) |
Constructor and Description |
---|
RemoteAgentSendClosureMessage(RemoteAgent<T> agent,
DataflowVariable<T> oldValue,
DataflowVariable<T> newValue) |
RemoteAgentSendMessage(RemoteAgent agent,
java.lang.Object message) |