Package | Description |
---|---|
groovyx.gpars.activeobject | |
groovyx.gpars.actor |
This package holds classes forming the public actor API.
|
groovyx.gpars.actor.impl |
This package holds classes some non-public aspects of actor implementation.
|
groovyx.gpars.actor.remote | |
groovyx.gpars.agent | |
groovyx.gpars.agent.remote | |
groovyx.gpars.dataflow |
This package holds classes for basic dataflow concurrency constructs, like dataflow variables, streams and threads.
|
groovyx.gpars.dataflow.expression | |
groovyx.gpars.dataflow.operator |
This package holds classes representing operators and channels necessary for full dataflow concurrency.
|
groovyx.gpars.dataflow.remote | |
groovyx.gpars.dataflow.stream | |
groovyx.gpars.serial |
This package holds classes used for actor identification in the network.
|
Modifier and Type | Class and Description |
---|---|
class |
InternalActor
Backs active objects and invokes all object's active methods.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractLoopingActor
Wraps all actors that repeatedly loop through incoming messages and hold no implicit state between subsequent messages.
|
class |
Actor
Actors are active objects, which borrow a thread from a thread pool.
|
class |
BlockingActor |
class |
DefaultActor
The DefaultActor class is the base for all stateful actors, who need to maintain implicit state between subsequent message arrivals.
|
class |
DynamicDispatchActor
A pooled actor allowing for an alternative structure of the message handling code.
|
class |
ReactiveActor
An actor representing a reactor.
|
class |
StaticDispatchActor<T>
Offers a statically dispatched and thus slightly faster alternative to the DynamicDispatchActor class.
|
Modifier and Type | Class and Description |
---|---|
class |
MessageStream
Represents a stream of messages and forms the base class for actors
|
static class |
MessageStream.RemoteMessageStream |
private static class |
MessageStream.ResultWaiter<V>
Represents a pending request for a reply from an actor.
|
class |
ReplyingMessageStream |
class |
RunnableBackedBlockingActor
Utility class to implement a blocking actor backed by any Runnable (including Closure)
|
class |
SequentialProcessingActor |
Modifier and Type | Class and Description |
---|---|
class |
RemoteActor
Proxy object for remote instance of Actor.
|
Modifier and Type | Method and Description |
---|---|
protected WithSerialId |
RemoteActor.MyRemoteHandle.createObject(SerialContext context) |
Modifier and Type | Class and Description |
---|---|
class |
Agent<T>
A special-purpose thread-safe non-blocking reference implementation inspired by Agents in Clojure.
|
(package private) class |
AgentBase<T>
Implements most of Agent's public method in Java
|
class |
AgentCore |
Modifier and Type | Class and Description |
---|---|
class |
RemoteAgent<T>
Proxy object for remote Agent instance.
|
Modifier and Type | Class and Description |
---|---|
class |
DataCallback
A helper class enabling the 'whenBound()' or 'getValAsync' functionality of a DataflowVariable and DataflowQueue,
as well as 'sendAndContinue()' on actors.
|
class |
DataCallbackWithPool
A helper class enabling the 'whenBound()' or 'getValAsync' functionality of a DataflowVariable and DataflowQueue,
whenever a thread pool instead of a PGroup is specified..
|
class |
DataflowBroadcast<T>
Offers a deterministic one-to-many and many-to-many messaging alternative to DataflowQueue.
|
class |
DataflowQueue<T>
Represents a thread-safe data flow stream.
|
class |
DataflowVariable<T>
Represents a thread-safe single-assignment, multi-read variable.
|
class |
LazyDataflowVariable<T>
Represents a thread-safe single-assignment, multi-read variable with delayed initialization.
|
class |
SyncDataflowBroadcast<T>
Offers a synchronous deterministic one-to-many and many-to-many messaging alternative to SyncDataflowQueue.
|
class |
SyncDataflowQueue<T>
Represents a thread-safe synchronous data flow stream.
|
class |
SyncDataflowVariable<T>
A synchronous variant of DataflowVariable, which blocks the writer as well as the readers.
|
Modifier and Type | Class and Description |
---|---|
class |
DataflowComplexExpression<T>
Provides the infrastructure for dataflow expressions to evaluate arguments.
|
class |
DataflowExpression<T>
The base class for all dataflow elements.
|
(package private) class |
DataflowExpression.DataflowExpressionsCollector
Listener for availability of data flow expressions we depend on.
|
private static class |
DataflowExpression.TransformMany<V> |
private static class |
DataflowExpression.TransformOne<V> |
class |
DataflowGetPropertyExpression<T>
A DFE, which evaluates a property when the receiver becomes available
|
class |
DataflowInvocationExpression
A dataflow expression, which invokes a method after the receiver as well as all the arguments become available
|
class |
RemoteDataflowExpression<T> |
Modifier and Type | Class and Description |
---|---|
(package private) class |
DataflowOperatorActor
An operator's internal actor.
|
(package private) class |
DataflowProcessorActor
A base actor class for operators' and selectors' actors
|
(package private) class |
DataflowSelectorActor
An selector's internal actor.
|
(package private) class |
ForkingDataflowOperatorActor
An operator's internal actor.
|
(package private) class |
ForkingDataflowSelectorActor
An selector's internal actor.
|
Modifier and Type | Class and Description |
---|---|
class |
RemoteDataflowBroadcast<T>
Proxy object for remote instance of Broadcast.
|
class |
RemoteDataflowQueue<T>
Proxy object for remote instance of Queue.
|
class |
RemoteDataflowVariable<T>
Proxy object for remote Variable instance.
|
Modifier and Type | Class and Description |
---|---|
class |
DataflowStreamWriteAdapter<T>
Adapts a DataflowStream to accommodate for the DataflowWriteChannel interface.
|
Modifier and Type | Field and Description |
---|---|
private WithSerialId |
SerialHandle.anchor |
Modifier and Type | Field and Description |
---|---|
private static java.lang.ref.ReferenceQueue<WithSerialId> |
SerialHandle.queue |
Modifier and Type | Method and Description |
---|---|
protected WithSerialId |
DefaultRemoteHandle.createObject(SerialContext context) |
protected abstract WithSerialId |
RemoteHandle.createObject(SerialContext context) |
Modifier and Type | Method and Description |
---|---|
static SerialHandle |
SerialHandle.create(WithSerialId obj,
java.util.UUID id) |
Constructor and Description |
---|
LocalSerialHandle(WithSerialId obj,
java.util.UUID uuid) |
RemoteSerialHandle(WithSerialId obj,
java.util.UUID uuid) |
SerialHandle(WithSerialId value,
java.util.UUID id)
Construct handle for object with given id to it
|