| 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) |