Uses of Class
groovyx.gpars.dataflow.operator.DataflowProcessor

Packages that use DataflowProcessor

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

Uses of DataflowProcessor in groovyx.gpars

Methods in groovyx.gpars that return DataflowProcessor

Modifier and Type	Method and Description
DataflowProcessor	DataflowMessagingRunnable.getOwningProcessor() Retrieves the owning processor (operator or selector) giving the DataflowMessagingRunnable a way to call methods like bindOutput()

Uses of DataflowProcessor in groovyx.gpars.dataflow

Methods in groovyx.gpars.dataflow that return DataflowProcessor

Modifier and Type	Method and Description
static DataflowProcessor	Dataflow.operator(DataflowReadChannel input, DataflowWriteChannel output, groovy.lang.Closure code) Creates an operator using the current parallel group
static DataflowProcessor	Dataflow.operator(DataflowReadChannel input, DataflowWriteChannel output, int maxForks, groovy.lang.Closure code) Creates an operator using the current parallel group
static DataflowProcessor	Dataflow.operator(java.util.List inputChannels, java.util.List outputChannels, groovy.lang.Closure code) Creates an operator using the current parallel group
static DataflowProcessor	Dataflow.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	Dataflow.operator(java.util.Map channels, groovy.lang.Closure code) Creates an operator using the default dataflow parallel group
static DataflowProcessor	Dataflow.prioritySelector(java.util.List inputChannels, java.util.List outputChannels) Creates a prioritizing selector using the default dataflow parallel group.
static DataflowProcessor	Dataflow.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	Dataflow.prioritySelector(java.util.Map channels) Creates a prioritizing selector using the default dataflow parallel group.
static DataflowProcessor	Dataflow.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	Dataflow.selector(java.util.List inputChannels, java.util.List outputChannels) Creates a selector using the default dataflow parallel group.
static DataflowProcessor	Dataflow.selector(java.util.List inputChannels, java.util.List outputChannels, groovy.lang.Closure code) Creates a selector using the default dataflow parallel group
static DataflowProcessor	Dataflow.selector(java.util.Map channels) Creates a selector using the default dataflow parallel group.
static DataflowProcessor	Dataflow.selector(java.util.Map channels, groovy.lang.Closure code) Creates a selector using the default dataflow parallel group
static DataflowProcessor	Dataflow.splitter(DataflowReadChannel inputChannel, java.util.List<DataflowWriteChannel> outputChannels) Creates a splitter copying its single input channel into all of its output channels.
static DataflowProcessor	Dataflow.splitter(DataflowReadChannel inputChannel, java.util.List<DataflowWriteChannel> outputChannels, int maxForks) Creates a splitter copying its single input channel into all of its output channels.

Uses of DataflowProcessor in groovyx.gpars.dataflow.operator

Subclasses of DataflowProcessor in groovyx.gpars.dataflow.operator

Modifier and Type	Class and Description
class	DataflowOperator Dataflow selectors and operators (processors) form the basic units in dataflow networks.
class	DataflowPrioritySelector Dataflow selectors and operators (processors) form the basic units in dataflow networks.
class	DataflowSelector Dataflow selectors and operators (processors) form the basic units in dataflow networks.

Fields in groovyx.gpars.dataflow.operator declared as DataflowProcessor

Modifier and Type	Field and Description
protected DataflowProcessor	DataflowProcessorActor.owningProcessor

Methods in groovyx.gpars.dataflow.operator that return DataflowProcessor

Modifier and Type	Method and Description
DataflowProcessor	DataflowProcessor.start() Starts a processor using the specified parallel group
DataflowProcessor	DataflowProcessor.start(PGroup group) Starts a processor using the specified parallel group

Methods in groovyx.gpars.dataflow.operator with parameters of type DataflowProcessor

Modifier and Type	Method and Description
void	DataflowEventAdapter.afterRun(DataflowProcessor processor, java.util.List<java.lang.Object> messages) Invoked when the operator completes a single run.
void	DataflowEventListener.afterRun(DataflowProcessor processor, java.util.List<java.lang.Object> messages) Invoked when the operator completes a single run When using maxForks, the method may be invoked from threads running the forks.
void	DataflowEventAdapter.afterStart(DataflowProcessor processor) Invoked immediately after the operator starts by a pooled thread before the first message is obtained
void	DataflowEventListener.afterStart(DataflowProcessor processor) Invoked immediately after the operator starts by a pooled thread before the first message is obtained
void	DataflowEventAdapter.afterStop(DataflowProcessor processor) Invoked immediately after the operator terminates
void	DataflowEventListener.afterStop(DataflowProcessor processor) Invoked immediately after the operator terminates
java.util.List<java.lang.Object>	DataflowEventAdapter.beforeRun(DataflowProcessor processor, java.util.List<java.lang.Object> messages) Invoked when all messages required to trigger the operator become available in the input channels.
java.util.List<java.lang.Object>	DataflowEventListener.beforeRun(DataflowProcessor processor, java.util.List<java.lang.Object> messages) Invoked when all messages required to trigger the operator become available in the input channels.
java.lang.Object	DataflowEventAdapter.controlMessageArrived(DataflowProcessor processor, DataflowReadChannel<java.lang.Object> channel, int index, java.lang.Object message) Invoked when a control message (instances of ControlMessage) becomes available in an input channel.
java.lang.Object	DataflowEventListener.controlMessageArrived(DataflowProcessor processor, DataflowReadChannel<java.lang.Object> channel, int index, java.lang.Object message) Invoked when a control message (instances of ControlMessage) becomes available in an input channel.
java.lang.Object	DataflowEventAdapter.customEvent(DataflowProcessor processor, java.lang.Object data) Invoked when the fireCustomEvent() method is triggered manually on a dataflow operator/selector.
java.lang.Object	DataflowEventListener.customEvent(DataflowProcessor processor, java.lang.Object data) Invoked when the fireCustomEvent() method is triggered manually on a dataflow operator/selector When using maxForks, the method may be invoked from threads running the forks.
java.lang.Object	DataflowEventAdapter.messageArrived(DataflowProcessor processor, DataflowReadChannel<java.lang.Object> channel, int index, java.lang.Object message) Invoked when a message becomes available in an input channel.
java.lang.Object	DataflowEventListener.messageArrived(DataflowProcessor processor, DataflowReadChannel<java.lang.Object> channel, int index, java.lang.Object message) Invoked when a message becomes available in an input channel.
java.lang.Object	DataflowEventAdapter.messageSentOut(DataflowProcessor processor, DataflowWriteChannel<java.lang.Object> channel, int index, java.lang.Object message) Invoked when a message is being bound to an output channel.
java.lang.Object	DataflowEventListener.messageSentOut(DataflowProcessor processor, DataflowWriteChannel<java.lang.Object> channel, int index, java.lang.Object message) Invoked when a message is being bound to an output channel.
boolean	DataflowEventAdapter.onException(DataflowProcessor processor, java.lang.Throwable e) Invoked if an exception occurs.
boolean	DataflowEventListener.onException(DataflowProcessor processor, java.lang.Throwable e) Invoked if an exception occurs.
void	DataflowEventAdapter.registered(DataflowProcessor processor) Invoked immediately after the listener has been attached to a dataflow processor.
void	DataflowEventListener.registered(DataflowProcessor processor) Invoked immediately after the listener has been attached to a dataflow processor.

Constructors in groovyx.gpars.dataflow.operator with parameters of type DataflowProcessor

Constructor and Description
DataflowProcessorActor(DataflowProcessor owningProcessor, PGroup group, java.util.List outputs, java.util.List inputs, groovy.lang.Closure code)

Uses of DataflowProcessor in groovyx.gpars.dataflow.operator.component

Fields in groovyx.gpars.dataflow.operator.component declared as DataflowProcessor

Modifier and Type	Field and Description
private DataflowProcessor	GracefulShutdownListener.processor

Methods in groovyx.gpars.dataflow.operator.component with parameters of type DataflowProcessor

Modifier and Type	Method and Description
void	GracefulShutdownListener.afterRun(DataflowProcessor processor, java.util.List<java.lang.Object> messages) Enters an idle state, so a notification needs to be sent to the monitor.
java.util.List<java.lang.Object>	GracefulShutdownListener.beforeRun(DataflowProcessor processor, java.util.List<java.lang.Object> messages) Entering a different non-idle state, so a notification needs to be sent to the monitor.
java.util.List<java.lang.Object>	ProcessorPauseResume.beforeRun(DataflowProcessor processor, java.util.List<java.lang.Object> messages)
java.lang.Object	GracefulShutdownListener.controlMessageArrived(DataflowProcessor processor, DataflowReadChannel<java.lang.Object> channel, int index, java.lang.Object message) Entering a non-idle state, so a notification needs to be sent to the monitor.
java.lang.Object	GracefulShutdownListener.messageArrived(DataflowProcessor processor, DataflowReadChannel<java.lang.Object> channel, int index, java.lang.Object message) Entering a non-idle state, so a notification needs to be sent to the monitor.
void	GracefulShutdownListener.registered(DataflowProcessor processor) When hooked into an operator/selectors, the listener will tap to its input channels to get notified about all incoming messages.

Uses of DataflowProcessor in groovyx.gpars.group

Methods in groovyx.gpars.group that return DataflowProcessor

Modifier and Type	Method and Description
DataflowProcessor	PGroup.operator(DataflowReadChannel input, DataflowWriteChannel output, groovy.lang.Closure code) Creates an operator using the current parallel group
DataflowProcessor	PGroup.operator(DataflowReadChannel input, DataflowWriteChannel output, int maxForks, groovy.lang.Closure code) Creates an operator using the current parallel group
DataflowProcessor	PGroup.operator(java.util.List inputChannels, java.util.List outputChannels, groovy.lang.Closure code) Creates an operator using the current parallel group
DataflowProcessor	PGroup.operator(java.util.List inputChannels, java.util.List outputChannels, int maxForks, groovy.lang.Closure code) Creates an operator using the current parallel group
DataflowProcessor	PGroup.operator(java.util.Map channels, groovy.lang.Closure code) Creates an operator using the current parallel group
DataflowProcessor	PGroup.prioritySelector(java.util.List inputChannels, java.util.List outputChannels) Creates a prioritizing selector using the default dataflow parallel group.
DataflowProcessor	PGroup.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.
DataflowProcessor	PGroup.prioritySelector(java.util.Map channels) Creates a prioritizing selector using the default dataflow parallel group.
DataflowProcessor	PGroup.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.
DataflowProcessor	PGroup.selector(java.util.List inputChannels, java.util.List outputChannels) Creates a selector using this parallel group.
DataflowProcessor	PGroup.selector(java.util.List inputChannels, java.util.List outputChannels, groovy.lang.Closure code) Creates a selector using this parallel group
DataflowProcessor	PGroup.selector(java.util.Map channels) Creates a selector using this parallel group.
DataflowProcessor	PGroup.selector(java.util.Map channels, groovy.lang.Closure code) Creates a selector using this parallel group
DataflowProcessor	PGroup.splitter(DataflowReadChannel inputChannel, java.util.List<DataflowWriteChannel> outputChannels) Creates a splitter copying its single input channel into all of its output channels.
DataflowProcessor	PGroup.splitter(DataflowReadChannel inputChannel, java.util.List<DataflowWriteChannel> outputChannels, int maxForks) Creates a splitter copying its single input channel into all of its output channels.