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.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.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.
|
static class |
Actor.RemoteActor |
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 | Method and Description |
---|---|
protected WithSerialId |
Actor.MyRemoteHandle.createObject(SerialContext context) |
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 |
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 |
DataflowVariable<T>
Represents a thread-safe single-assignment, multi-read variable.
|
static class |
DataflowVariable.RemoteDataflowVariable<T> |
class |
LazyDataflowVariable<T>
Represents a thread-safe single-assignment, multi-read variable with delayed initialization.
|
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 | 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 |
---|
SerialHandle.LocalSerialHandle(WithSerialId obj,
java.util.UUID uuid) |
SerialHandle.RemoteSerialHandle(WithSerialId obj,
java.util.UUID uuid) |
SerialHandle(WithSerialId value,
java.util.UUID id)
Construct handle for object with given id to it
|