Dataflow (org.codehaus.gpars)

groovyx.gpars.dataflow.Dataflow

Contains factory methods to create dataflow actors and starting them.
Authors:
Vaclav Pech, Dierk Koenig Date: Jun 4, 2009

Field Summary

Fields
Modifiers	Name	Description
`static PGroup`	`DATA_FLOW_GROUP`	The parallel group used by all Dataflow Concurrency actors by default.
`static java.lang.ThreadLocal<PGroup>`	`activeParallelGroup`	Maps threads/tasks to parallel groups they belong to

Constructor Summary

Constructors
Constructor and description
`Dataflow ()`

Methods Summary

Methods
Type	Name and description
`static Promise<T>`	`lazyTask(groovy.lang.Closure<T> code)` Creates a new task assigned to a thread from the default dataflow parallel group.
`static Promise<T>`	`lazyTask(java.util.concurrent.Callable<T> callable)` Creates a new task assigned to a thread from the current parallel group.
`static DataflowProcessor`	`operator(java.util.Map channels, groovy.lang.Closure code)` Creates an operator using the default dataflow parallel group
`static DataflowProcessor`	`operator(java.util.List inputChannels, java.util.List outputChannels, groovy.lang.Closure code)` Creates an operator using the current parallel group
`static DataflowProcessor`	`operator(java.util.List inputChannels, java.util.List outputChannels, int maxForks, groovy.lang.Closure code)` Creates an operator using the current parallel group
`static DataflowProcessor`	`operator(DataflowReadChannel input, DataflowWriteChannel output, groovy.lang.Closure code)` Creates an operator using the current parallel group
`static DataflowProcessor`	`operator(DataflowReadChannel input, DataflowWriteChannel output, int maxForks, groovy.lang.Closure code)` Creates an operator using the current parallel group
`static DataflowProcessor`	`prioritySelector(java.util.Map channels, groovy.lang.Closure code)` Creates a prioritizing selector using the default dataflow parallel group Input with lower position index have higher priority.
`static DataflowProcessor`	`prioritySelector(java.util.List inputChannels, java.util.List outputChannels, groovy.lang.Closure code)` Creates a prioritizing selector using the default dataflow parallel group Input with lower position index have higher priority.
`static DataflowProcessor`	`prioritySelector(java.util.Map channels)` Creates a prioritizing selector using the default dataflow parallel group.
`static DataflowProcessor`	`prioritySelector(java.util.List inputChannels, java.util.List outputChannels)` Creates a prioritizing selector using the default dataflow parallel group.
`static PGroup`	`retrieveCurrentDFPGroup()` Retrieves the thread-local value of the active PGroup or the default DataflowGroup
`static Select<?>`	`select(SelectableChannel<?>... channels)` Creates a select using the default dataflow parallel group.
`static Select<?>`	`select(java.util.List<? extends SelectableChannel> channels)` Creates a select using the default dataflow parallel group.
`static DataflowProcessor`	`selector(java.util.Map channels, groovy.lang.Closure code)` Creates a selector using the default dataflow parallel group
`static DataflowProcessor`	`selector(java.util.List inputChannels, java.util.List outputChannels, groovy.lang.Closure code)` Creates a selector using the default dataflow parallel group
`static DataflowProcessor`	`selector(java.util.Map channels)` Creates a selector using the default dataflow parallel group.
`static DataflowProcessor`	`selector(java.util.List inputChannels, java.util.List outputChannels)` Creates a selector using the default dataflow parallel group.
`static DataflowProcessor`	`splitter(DataflowReadChannel inputChannel, java.util.List<DataflowWriteChannel> outputChannels)` Creates a splitter copying its single input channel into all of its output channels.
`static DataflowProcessor`	`splitter(DataflowReadChannel inputChannel, java.util.List<DataflowWriteChannel> outputChannels, int maxForks)` Creates a splitter copying its single input channel into all of its output channels.
`static Promise<T>`	`task(groovy.lang.Closure<T> code)` Creates a new task assigned to a thread from the default dataflow parallel group.
`static Promise<T>`	`task(java.util.concurrent.Callable<T> callable)` Creates a new task assigned to a thread from the current parallel group.
`static Promise<java.lang.Object>`	`task(java.lang.Runnable runnable)` Creates a new task assigned to a thread from the current parallel group.
`static java.lang.Object`	`usingGroup(PGroup group, groovy.lang.Closure code)` Sets the supplied PGroup as the default for the given block of code.
`static Promise<T>`	`whenAllBound(java.util.List<Promise> promises, groovy.lang.Closure<T> code)` Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
`static Promise<T>`	`whenAllBound(Promise promise1, groovy.lang.Closure<T> code)` Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
`static Promise<T>`	`whenAllBound(Promise promise1, Promise promise2, groovy.lang.Closure<T> code)` Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
`static Promise<T>`	`whenAllBound(Promise promise1, Promise promise2, Promise promise3, groovy.lang.Closure<T> code)` Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
`static Promise<T>`	`whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code)` Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
`static Promise<T>`	`whenAllBound(java.util.List<Promise> promises, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler)` Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
`static Promise<T>`	`whenAllBound(Promise promise1, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler)` Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
`static Promise<T>`	`whenAllBound(Promise promise1, Promise promise2, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler)` Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
`static Promise<T>`	`whenAllBound(Promise promise1, Promise promise2, Promise promise3, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler)` Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
`static Promise<T>`	`whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler)` Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.

Inherited Methods Summary

Inherited Methods
Methods inherited from class	Name
`class java.lang.Object`	`java.lang.Object#wait(), java.lang.Object#wait(long, int), java.lang.Object#wait(long), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll()`

- Field Detail
  - public static final PGroup DATA_FLOW_GROUP
    
    The parallel group used by all Dataflow Concurrency actors by default.
  - public static final java.lang.ThreadLocal<PGroup> activeParallelGroup
    
    Maps threads/tasks to parallel groups they belong to
- Constructor Detail
  - Dataflow()
- Method Detail
  - public static Promise<T> lazyTask(groovy.lang.Closure<T> code)
    
    Creates a new task assigned to a thread from the default dataflow parallel group. The task is lazy, since it only gets executed if the returned Promise instance is read or a then-callback is registered on it. Tasks are a lightweight version of dataflow operators, which do not define their communication channels explicitly, but can only exchange data using explicit DataflowVariables and Streams.
    Returns:
    A LazyDataflowVariable, which gets assigned the value returned from the supplied code
    Parameters:
    code - The task body to run
  - public static Promise<T> lazyTask(java.util.concurrent.Callable<T> callable)
    
    Creates a new task assigned to a thread from the current parallel group. The task is lazy, since it only gets executed if the returned Promise instance is read or a then-callback is registered on it. Tasks are a lightweight version of dataflow operators, which do not define their communication channels explicitly, but can only exchange data using explicit DataflowVariables and Streams. Registers itself with Dataflow for nested 'whenBound' handlers to use the same group.
    Returns:
    A LazyDataflowVariable, which gets assigned the value returned from the supplied code
    Parameters:
    callable - The task body to run
  - public static DataflowProcessor operator(java.util.Map channels, @groovy.lang.DelegatesTo(DataflowOperator.class) groovy.lang.Closure code)
    
    Creates an operator using the default dataflow parallel group
    Returns:
    A new active operator instance
    Parameters:
    channels - A map specifying "inputs" and "outputs" - dataflow channels (instances of the DataflowQueue or DataflowVariable classes) to use for inputs and outputs
    code - The operator's body to run each time all inputs have a value to read
  - public static DataflowProcessor operator(java.util.List inputChannels, java.util.List outputChannels, @groovy.lang.DelegatesTo(DataflowOperator.class) groovy.lang.Closure code)
    
    Creates an operator using the current parallel group
    Returns:
    A new active operator instance
    Parameters:
    inputChannels - dataflow channels to use for input
    outputChannels - dataflow channels to use for output
    code - The operator's body to run each time all inputs have a value to read
  - public static DataflowProcessor operator(java.util.List inputChannels, java.util.List outputChannels, int maxForks, @groovy.lang.DelegatesTo(DataflowOperator.class) groovy.lang.Closure code)
    
    Creates an operator using the current parallel group
    Returns:
    A new active operator instance
    Parameters:
    inputChannels - dataflow channels to use for input
    outputChannels - dataflow channels to use for output
    maxForks - Number of parallel threads running operator's body, defaults to 1
    code - The operator's body to run each time all inputs have a value to read
  - public static DataflowProcessor operator(DataflowReadChannel input, DataflowWriteChannel output, @groovy.lang.DelegatesTo(DataflowOperator.class) groovy.lang.Closure code)
    
    Creates an operator using the current parallel group
    Returns:
    A new active operator instance
    Parameters:
    input - a dataflow channel to use for input
    output - a dataflow channel to use for output
    code - The operator's body to run each time all inputs have a value to read
  - public static DataflowProcessor operator(DataflowReadChannel input, DataflowWriteChannel output, int maxForks, @groovy.lang.DelegatesTo(DataflowOperator.class) groovy.lang.Closure code)
    
    Creates an operator using the current parallel group
    Returns:
    A new active operator instance
    Parameters:
    input - a dataflow channel to use for input
    output - a dataflow channel to use for output
    maxForks - Number of parallel threads running operator's body, defaults to 1
    code - The operator's body to run each time all inputs have a value to read
  - public static DataflowProcessor prioritySelector(java.util.Map channels, @groovy.lang.DelegatesTo(DataflowSelector.class) groovy.lang.Closure code)
    
    Creates a prioritizing selector using the default dataflow parallel group Input with lower position index have higher priority.
    Returns:
    A new active selector instance
    Parameters:
    channels - A map specifying "inputs" and "outputs" - dataflow channels (instances of the DataflowQueue or DataflowVariable classes) to use for inputs and outputs
    code - The selector's body to run each time a value is available in any of the inputs channels
  - public static DataflowProcessor prioritySelector(java.util.List inputChannels, java.util.List outputChannels, @groovy.lang.DelegatesTo(DataflowSelector.class) groovy.lang.Closure code)
    
    Creates a prioritizing selector using the default dataflow parallel group Input with lower position index have higher priority.
    Returns:
    A new active selector instance
    Parameters:
    inputChannels - dataflow channels to use for input
    outputChannels - dataflow channels to use for output
    code - The selector's body to run each time a value is available in any of the inputs channels
  - public static DataflowProcessor prioritySelector(java.util.Map channels)
    
    Creates a prioritizing selector using the default dataflow parallel group. Since no body is provided, the selector will simply copy the incoming values to all output channels. Input with lower position index have higher priority.
    Returns:
    A new active selector instance
    Parameters:
    channels - A map specifying "inputs" and "outputs" - dataflow channels (instances of the DataflowQueue or DataflowVariable classes) to use for inputs and outputs
  - public static DataflowProcessor prioritySelector(java.util.List inputChannels, java.util.List outputChannels)
    
    Creates a prioritizing selector using the default dataflow parallel group. Since no body is provided, the selector will simply copy the incoming values to all output channels. Input with lower position index have higher priority.
    Returns:
    A new active selector instance
    Parameters:
    inputChannels - dataflow channels to use for input
    outputChannels - dataflow channels to use for output
  - public static PGroup retrieveCurrentDFPGroup()
    
    Retrieves the thread-local value of the active PGroup or the default DataflowGroup
    Returns:
    The PGroup to use for DF within the current thread
  - public static Select<?> select(SelectableChannel<?>... channels)
    
    Creates a select using the default dataflow parallel group. The returns Select instance will allow the user to obtain values from the supplied dataflow variables or streams as they become available.
    Returns:
    A new select instance
    Parameters:
    channels - Dataflow variables or streams to wait for values on
  - public static Select<?> select(java.util.List<? extends SelectableChannel> channels)
    
    Creates a select using the default dataflow parallel group. The returns Select instance will allow the user to obtain values from the supplied dataflow variables or streams as they become available.
    Returns:
    A new select instance
    Parameters:
    channels - Dataflow variables or streams to wait for values on
  - public static DataflowProcessor selector(java.util.Map channels, @groovy.lang.DelegatesTo(DataflowSelector.class) groovy.lang.Closure code)
    
    Creates a selector using the default dataflow parallel group
    Returns:
    A new active selector instance
    Parameters:
    channels - A map specifying "inputs" and "outputs" - dataflow channels (instances of the DataflowQueue or DataflowVariable classes) to use for inputs and outputs
    code - The selector's body to run each time a value is available in any of the inputs channels
  - public static DataflowProcessor selector(java.util.List inputChannels, java.util.List outputChannels, @groovy.lang.DelegatesTo(DataflowSelector.class) groovy.lang.Closure code)
    
    Creates a selector using the default dataflow parallel group
    Returns:
    A new active selector instance
    Parameters:
    inputChannels - dataflow channels to use for input
    outputChannels - dataflow channels to use for output
    code - The selector's body to run each time a value is available in any of the inputs channels
  - public static DataflowProcessor selector(java.util.Map channels)
    
    Creates a selector using the default dataflow parallel group. Since no body is provided, the selector will simply copy the incoming values to all output channels.
    Returns:
    A new active selector instance
    Parameters:
    channels - A map specifying "inputs" and "outputs" - dataflow channels (instances of the DataflowQueue or DataflowVariable classes) to use for inputs and outputs
  - public static DataflowProcessor selector(java.util.List inputChannels, java.util.List outputChannels)
    
    Creates a selector using the default dataflow parallel group. Since no body is provided, the selector will simply copy the incoming values to all output channels.
    Returns:
    A new active selector instance
    Parameters:
    inputChannels - dataflow channels to use for input
    outputChannels - dataflow channels to use for output
  - public static DataflowProcessor splitter(DataflowReadChannel inputChannel, java.util.List<DataflowWriteChannel> outputChannels)
    
    Creates a splitter copying its single input channel into all of its output channels. The created splitter will be part of the default parallel group Input with lower position index have higher priority.
    Returns:
    A new active splitter instance
    Parameters:
    inputChannel - The channel to read values from
    outputChannels - A list of channels to output to
  - public static DataflowProcessor splitter(DataflowReadChannel inputChannel, java.util.List<DataflowWriteChannel> outputChannels, int maxForks)
    
    Creates a splitter copying its single input channel into all of its output channels. The created splitter will be part of this parallel group Input with lower position index have higher priority.
    Returns:
    A new active splitter instance
    Parameters:
    inputChannel - The channel to read values from
    outputChannels - A list of channels to output to
    maxForks - Number of threads running the splitter's body, defaults to 1
  - public static Promise<T> task(groovy.lang.Closure<T> code)
    
    Creates a new task assigned to a thread from the default dataflow parallel group. Tasks are a lightweight version of dataflow operators, which do not define their communication channels explicitly, but can only exchange data using explicit DataflowVariables and Streams.
    Returns:
    A DataflowVariable, which gets assigned the value returned from the supplied code
    Parameters:
    code - The task body to run
  - public static Promise<T> task(java.util.concurrent.Callable<T> callable)
    
    Creates a new task assigned to a thread from the current parallel group. Tasks are a lightweight version of dataflow operators, which do not define their communication channels explicitly, but can only exchange data using explicit DataflowVariables and Streams. Registers itself with Dataflow for nested 'whenBound' handlers to use the same group.
    Returns:
    A DataflowVariable, which gets assigned the value returned from the supplied code
    Parameters:
    callable - The task body to run
  - public static Promise<java.lang.Object> task(java.lang.Runnable runnable)
    
    Creates a new task assigned to a thread from the current parallel group. Tasks are a lightweight version of dataflow operators, which do not define their communication channels explicitly, but can only exchange data using explicit DataflowVariables and Streams. Registers itself with Dataflow for nested 'whenBound' handlers to use the same group.
    Returns:
    A DataflowVariable, which gets bound to null once the supplied code finishes
    Parameters:
    runnable - The task body to run
  - public static java.lang.Object usingGroup(PGroup group, groovy.lang.Closure code)
    
    Sets the supplied PGroup as the default for the given block of code. All dataflow functions, such as task or operator and callback handlers, will use the PGroup and its thread pool for their scheduling.
    Returns:
    The value returned from the supplied code block
    Parameters:
    group - The group to make the default inside the block
    code - The code to run with overriden default
  - public static Promise<T> whenAllBound(java.util.List<Promise> promises, groovy.lang.Closure<T> code)
    
    Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
    Returns:
    A promise for the final result
    Parameters:
    promises - The promises to wait for
    code - A closure to execute with concrete values for each of the supplied promises
    - The type of the final result
  - public static Promise<T> whenAllBound(Promise promise1, groovy.lang.Closure<T> code)
    
    Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
    Returns:
    A promise for the final result
    Parameters:
    promise1 - The promises to wait for
    code - A closure to execute with concrete values for each of the supplied promises
    - The type of the final result
  - public static Promise<T> whenAllBound(Promise promise1, Promise promise2, groovy.lang.Closure<T> code)
    
    Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
    Returns:
    A promise for the final result
    Parameters:
    promise1 - The promises to wait for
    promise2 - The promises to wait for
    code - A closure to execute with concrete values for each of the supplied promises
    - The type of the final result
  - public static Promise<T> whenAllBound(Promise promise1, Promise promise2, Promise promise3, groovy.lang.Closure<T> code)
    
    Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
    Returns:
    A promise for the final result
    Parameters:
    promise1 - The promises to wait for
    promise2 - The promises to wait for
    promise3 - The promises to wait for
    code - A closure to execute with concrete values for each of the supplied promises
    - The type of the final result
  - public static Promise<T> whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code)
    
    Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
    Returns:
    A promise for the final result
    Parameters:
    promise1 - The promises to wait for
    promise2 - The promises to wait for
    promise3 - The promises to wait for
    promise4 - The promises to wait for
    code - A closure to execute with concrete values for each of the supplied promises
    - The type of the final result
  - public static Promise<T> whenAllBound(java.util.List<Promise> promises, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler)
    
    Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
    Returns:
    A promise for the final result
    Parameters:
    promises - The promises to wait for
    code - A closure to execute with concrete values for each of the supplied promises
    errorHandler - A closure handling an exception (an instance of Throwable), if it gets bound
    - The type of the final result
  - public static Promise<T> whenAllBound(Promise promise1, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler)
    
    Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
    Returns:
    A promise for the final result
    Parameters:
    promise1 - The promises to wait for
    code - A closure to execute with concrete values for each of the supplied promises
    errorHandler - A closure handling an exception (an instance of Throwable), if it gets bound
    - The type of the final result
  - public static Promise<T> whenAllBound(Promise promise1, Promise promise2, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler)
    
    Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
    Returns:
    A promise for the final result
    Parameters:
    promise1 - The promises to wait for
    promise2 - The promises to wait for
    code - A closure to execute with concrete values for each of the supplied promises
    errorHandler - A closure handling an exception (an instance of Throwable), if it gets bound
    - The type of the final result
  - public static Promise<T> whenAllBound(Promise promise1, Promise promise2, Promise promise3, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler)
    
    Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
    Returns:
    A promise for the final result
    Parameters:
    promise1 - The promises to wait for
    promise2 - The promises to wait for
    promise3 - The promises to wait for
    code - A closure to execute with concrete values for each of the supplied promises
    errorHandler - A closure handling an exception (an instance of Throwable), if it gets bound
    - The type of the final result
  - public static Promise<T> whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler)
    
    Without blocking the thread waits for all the promises to get bound and then passes them to the supplied closure.
    Returns:
    A promise for the final result
    Parameters:
    promise1 - The promises to wait for
    promise2 - The promises to wait for
    promise3 - The promises to wait for
    promise4 - The promises to wait for
    code - A closure to execute with concrete values for each of the supplied promises
    errorHandler - A closure handling an exception (an instance of Throwable), if it gets bound
    - The type of the final result

Summary:
Field
Constructor
Method

| Detail:
Field
Constructor
Method

[Java] Class Dataflow

Field Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Field Detail

public static final PGroup DATA_FLOW_GROUP

public static final java.lang.ThreadLocal<PGroup> activeParallelGroup

Constructor Detail

Dataflow()

Method Detail

public static Promise<T> lazyTask(groovy.lang.Closure<T> code)

public static Promise<T> lazyTask(java.util.concurrent.Callable<T> callable)

public static DataflowProcessor operator(java.util.Map channels, @groovy.lang.DelegatesTo(DataflowOperator.class) groovy.lang.Closure code)

public static DataflowProcessor operator(java.util.List inputChannels, java.util.List outputChannels, @groovy.lang.DelegatesTo(DataflowOperator.class) groovy.lang.Closure code)

public static DataflowProcessor operator(java.util.List inputChannels, java.util.List outputChannels, int maxForks, @groovy.lang.DelegatesTo(DataflowOperator.class) groovy.lang.Closure code)

public static DataflowProcessor operator(DataflowReadChannel input, DataflowWriteChannel output, @groovy.lang.DelegatesTo(DataflowOperator.class) groovy.lang.Closure code)

public static DataflowProcessor operator(DataflowReadChannel input, DataflowWriteChannel output, int maxForks, @groovy.lang.DelegatesTo(DataflowOperator.class) groovy.lang.Closure code)

public static DataflowProcessor prioritySelector(java.util.Map channels, @groovy.lang.DelegatesTo(DataflowSelector.class) groovy.lang.Closure code)

public static DataflowProcessor prioritySelector(java.util.List inputChannels, java.util.List outputChannels, @groovy.lang.DelegatesTo(DataflowSelector.class) groovy.lang.Closure code)

public static DataflowProcessor prioritySelector(java.util.Map channels)

public static DataflowProcessor prioritySelector(java.util.List inputChannels, java.util.List outputChannels)

public static PGroup retrieveCurrentDFPGroup()

public static Select<?> select(SelectableChannel<?>... channels)

public static Select<?> select(java.util.List<? extends SelectableChannel> channels)

public static DataflowProcessor selector(java.util.Map channels, @groovy.lang.DelegatesTo(DataflowSelector.class) groovy.lang.Closure code)

public static DataflowProcessor selector(java.util.List inputChannels, java.util.List outputChannels, @groovy.lang.DelegatesTo(DataflowSelector.class) groovy.lang.Closure code)

public static DataflowProcessor selector(java.util.Map channels)

public static DataflowProcessor selector(java.util.List inputChannels, java.util.List outputChannels)

public static DataflowProcessor splitter(DataflowReadChannel inputChannel, java.util.List<DataflowWriteChannel> outputChannels)

public static DataflowProcessor splitter(DataflowReadChannel inputChannel, java.util.List<DataflowWriteChannel> outputChannels, int maxForks)

public static Promise<T> task(groovy.lang.Closure<T> code)

public static Promise<T> task(java.util.concurrent.Callable<T> callable)

public static Promise<java.lang.Object> task(java.lang.Runnable runnable)

public static java.lang.Object usingGroup(PGroup group, groovy.lang.Closure code)

public static Promise<T> whenAllBound(java.util.List<Promise> promises, groovy.lang.Closure<T> code)

public static Promise<T> whenAllBound(Promise promise1, groovy.lang.Closure<T> code)

public static Promise<T> whenAllBound(Promise promise1, Promise promise2, groovy.lang.Closure<T> code)

public static Promise<T> whenAllBound(Promise promise1, Promise promise2, Promise promise3, groovy.lang.Closure<T> code)

public static Promise<T> whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code)

public static Promise<T> whenAllBound(java.util.List<Promise> promises, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler)

public static Promise<T> whenAllBound(Promise promise1, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler)

public static Promise<T> whenAllBound(Promise promise1, Promise promise2, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler)

public static Promise<T> whenAllBound(Promise promise1, Promise promise2, Promise promise3, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler)

public static Promise<T> whenAllBound(Promise promise1, Promise promise2, Promise promise3, Promise promise4, groovy.lang.Closure<T> code, groovy.lang.Closure<T> errorHandler)