org.codehaus.gpars

Package groovyx.gpars.dataflow.impl

 

Interface Summary
BindErrorDistributor Fires requested events
BindErrorListenerManager @author Vaclav Pech
DataflowChannelEventDistributor @author Vaclav Pech
DataflowChannelEventListenerManager @author Vaclav Pech
SelectRequest Represents a request for value from a select.
 


Class Summary
DataflowChannelEventOrchestrator Groups the listener-related functionality shared by dataflow channels
GuardedSelectRequest 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
SelectBase The implementation of the core for all selects.
SelectCallback 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 @author Vaclav Pech
 


Copyright © 2008–2013 Václav Pech. All Rights Reserved.