| Package | Description |
|---|---|
| groovyx.gpars.agent | |
| groovyx.gpars.agent.remote | |
| groovyx.gpars.group | |
| groovyx.gpars.remote.message |
This package holds message classes for the remote actors implementation.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> Agent<T> |
Agent.agent(T state)
Creates an agent instance initialized with the given state.
|
static <T> Agent<T> |
Agent.agent(T state,
groovy.lang.Closure copy)
Creates an agent instance initialized with the given state.
|
static <T> Agent<T> |
Agent.fairAgent(T state)
Creates an agent instance initialized with the given state, which will cooperate in thread sharing with other Agent instances
in a fair manner.
|
static <T> Agent<T> |
Agent.fairAgent(T state,
groovy.lang.Closure copy)
Creates an agent instance initialized with the given state, which will cooperate in thread sharing with other agents and actors in a fair manner.
|
| Modifier and Type | Field and Description |
|---|---|
private java.util.concurrent.ConcurrentMap<java.lang.String,Agent<?>> |
RemoteAgents.publishedAgents
Stores Agents published in context of this instance of RemoteAgents.
|
| Modifier and Type | Method and Description |
|---|---|
void |
RemoteAgents.publish(Agent<?> agent,
java.lang.String name)
Publishes
Agent under given name. |
| Modifier and Type | Method and Description |
|---|---|
<T> Agent<T> |
PGroup.agent(T state)
Creates an agent instance initialized with the given state
|
<T> Agent<T> |
PGroup.agent(T state,
groovy.lang.Closure copy)
Creates an agent instance initialized with the given state
|
<T> Agent<T> |
PGroup.fairAgent(T state)
Creates an agent instance initialized with the given state, which will cooperate in thread sharing with other agents and actors in a fair manner.
|
<T> Agent<T> |
PGroup.fairAgent(T state,
groovy.lang.Closure copy)
Creates an agent instance initialized with the given state, which will cooperate in thread sharing with other agents and actors in a fair manner.
|
| Constructor and Description |
|---|
RemoteAgentReplyMsg(java.lang.String name,
Agent<?> agent) |