Package org.apache.reef.wake.impl

Class Summary

Class	Description
BlockingEventHandler<T>	An EventHandler that blocks until a set number of Events has been received.
BlockingSignalEventHandler<T>	An EventHandler that blocks until a set number of Events has been received.
DefaultIdentifierFactory	Default remote identifier factory that creates a specific remote identifier from a string representation A string representation is broken into two parts type and type-specific details separated by "://" A remote identifier implementation should implement a constructor that accepts a string.
DefaultThreadFactory	A default thread factory implementation that names created threads
ForkPoolStage<T>	This Wake event handling stage uses a ForkJoinPool to submit tasks.
IndependentIterationsThreadPoolStage<T>	This stage uses a thread pool to schedule events in parallel.
LoggingEventHandler<T>	A logging event handler
LoggingUtils	Utility for logging
LoggingVoidEventHandler	A logging void event handler
MergingEventHandler<L,R>	An EventHandler combines two events of different types into a single Pair of events.
MergingEventHandler.Pair<S1,S2>
MissingStartHandlerHandler	The EventHandler used as the default for the Clock.StartHandler event.
MultiEventHandler<T>	Event handler that dispatches an event to a specific handler based on an event class type
OpaqueLocalIdentifier
PeriodicEvent	Periodic event for timers
PubSubEventHandler<T>	Event handler that provides publish/subscribe interfaces
SingleThreadStage<T>	Single thread stage that runs the event handler
StageManager	A manager that manages all the stage
SyncStage<T>	Stage that synchronously executes an event handler
ThreadPoolStage<T>	Stage that executes an event handler with a thread pool
TimerStage	Stage that triggers an event handler periodically
WakeSharedPool
WakeUncaughtExceptionHandler	Exception handler for uncaught exceptions