| Package | Description |
|---|---|
| groovyx.gpars |
This package holds classes for asynchronous collection processing.
|
| groovyx.gpars.dataflow |
This package holds classes for basic dataflow concurrency constructs, like dataflow variables, streams and threads.
|
| groovyx.gpars.dataflow.operator |
This package holds classes representing operators and channels necessary for full dataflow concurrency.
|
| groovyx.gpars.dataflow.operator.component | |
| groovyx.gpars.group |
| Class and Description |
|---|
| DataflowProcessor
Dataflow selectors and operators (processors) form the basic units in dataflow networks.
|
| Class and Description |
|---|
| DataflowProcessor
Dataflow selectors and operators (processors) form the basic units in dataflow networks.
|
| Class and Description |
|---|
| ControlMessage
A marker interface indicating control dataflow messages, which in general do not get propagated to the operator's body
|
| DataflowEventListener
Enables external entities to observe the state of dataflow selectors and operators
|
| DataflowOperator
Dataflow selectors and operators (processors) form the basic units in dataflow networks.
|
| DataflowOperatorActor
An operator's internal actor.
|
| DataflowProcessor
Dataflow selectors and operators (processors) form the basic units in dataflow networks.
|
| DataflowProcessorActor
A base actor class for operators' and selectors' actors
|
| DataflowSelector
Dataflow selectors and operators (processors) form the basic units in dataflow networks.
|
| DataflowSelectorActor
An selector's internal actor.
|
| Pipeline
A builder for operator pipelines.
|
| PoisonPill
Represents the poison for dataflow operators.
|
| PoisonTrackCounter
A helper class used by poison messages to count terminated dataflow processors
|
| StopGently
A message to stop operators' actors once they handle the next round of messages.
|
| Class and Description |
|---|
| DataflowEventAdapter
A default empty implementation of DataflowEventListener
|
| DataflowEventListener
Enables external entities to observe the state of dataflow selectors and operators
|
| DataflowProcessor
Dataflow selectors and operators (processors) form the basic units in dataflow networks.
|
| Class and Description |
|---|
| DataflowProcessor
Dataflow selectors and operators (processors) form the basic units in dataflow networks.
|