Package org.apache.reef.wake.impl

Wake's implementation.

See: Description

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.
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>	A pair having two independent typed items.
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.
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	This implementation uses the fork join framework to reduce the cost of spawning events in stages.
WakeUncaughtExceptionHandler	Exception handler for uncaught exceptions.

Package org.apache.reef.wake.impl Description

Wake's implementation.