|
Groovy Documentation | |||||||
FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectgpars.dataflow.DataFlow
abstract class DataFlow
Contains factory methods to create dataflow actors and starting them.
Field Summary | |
---|---|
static DataFlowPGroup |
DATA_FLOW_GROUP
The actor group used by all Dataflow Concurrency actors by default. |
Method Summary | |
---|---|
static DataFlowOperator
|
operator(Map channels, groovy.lang.Closure code)
Creates an operator using the default operator actor group |
static Actor
|
start(groovy.lang.Closure code)
Creates a new instance of SingleRunActor to run the supplied code. |
static void
|
task(groovy.lang.Closure code)
Creates a new task assigned to a thread from the default dataflow actor group. |
Methods inherited from class Object | |
---|---|
wait, wait, wait, equals, toString, hashCode, getClass, notify, notifyAll |
Field Detail |
---|
public static final DataFlowPGroup DATA_FLOW_GROUP
Method Detail |
---|
static DataFlowOperator operator(Map channels, groovy.lang.Closure code)
channels
- A map specifying "inputs" and "outputs" - dataflow channels (instances of the DataFlowStream or DataFlowVariable classes) to use for inputs and outputscode
- The operator's body to run each time all inputs have a value to read
static Actor start(groovy.lang.Closure code)
static void task(groovy.lang.Closure code)
code
- The task body to run
Groovy Documentation