Package groovyx.gpars.dataflow.impl

Interface Summary

DataflowChannelEventDistibutor<T>
DataflowChannelEventListenerManager<T>
SelectRequest<T>	Represents a request for value from a select.

Class Summary

DataflowChannelEventOrchestrator<T>	Groups the listener-related functionality shared by dataflow channels
GuardedSelectRequest<T>	The base implementation of the SelectRequest interface, providing a useful default masking (guarding) functionality.
ResizeableCountDownLatch	CountDownLatch with the ability to change the number of waiting parties
ResizeableCountDownLatch.Sync	Synchronization control For CountDownLatch.
SelectBase<T>	The implementation of the core for all selects.
SelectCallback<T>	A closure registered with all the input channels on the wheneverBound() event to inform the Select about a value being available in a particular channel.
ThenMessagingRunnable<T,V>