Package org.fusesource.hawtdispatch

HawtDispatch HawtDispatch is an abstract model for expressing concurrency via simple but powerful API.

See:
          Description

Interface Summary
CustomDispatchSource<Event,MergedEvent> A dispatch source that is used to coalesce multiple application generated events for later processing by the dispatch source event handler.
Dispatcher The Dispatcher interface is used to get or create dispatch objects such as global queues, thread queues, serial queues, or dispatch sources.
DispatchObject Implemented by dispatch objects that can be configured with a target queue that it uses for executing the object's asynchronous tasks.
DispatchQueue Dispatch queues are lightweight objects to which runnable objects may be submitted for asynchronous execution and therefore are Executor objects.
DispatchSource A dispatch source is used to monitor low-level system objects and automatically submit a handler runnable to a dispatch queue in response to events.
EventAggregator<Event,MergedEvent> The EventAggregator interface is used by the CustomDispatchSource objects to handle coalescing data before passing it to the application.
OrderedEventAggregator<Event,MergedEvent> This class should be implemented by Aggregator classes which depend on FIFO ordering of events from the point of view of the serial queue which merges events into it.
Retained Implemented by dispatch objects which use a reference counted life cycle.
Suspendable Implemented by dispatch objects which can suspend the execution of dispatch tasks.
 

Class Summary
AggregatingExecutor Sends runnable tasks to a DispatchQueue via a an EventAggregator so that they first batch up on the sender side before being sent to the DispatchQueue which then executes that tasks.
BaseRetained Base class that implements the Retained interface.
Dispatch The Dispatch class is used to get or create dispatch objects such as global queues, thread queues, serial queues, or dispatch sources.
DispatchQueueProxy This class creates proxy objects that allow you to easily service all method calls to an interface via a DispatchQueue.
EventAggregators  
Metrics
Task We prefer the use of Task over Runnable since the JVM can more efficiently invoke methods of an abstract class than a interface.
TaskWrapper
 

Enum Summary
DispatchPriority Defines the supported global/concurrent queue priorities.
DispatchQueue.QueueType Defines the types of dispatch queues supported by the system.
 

Exception Summary
ShutdownException This exception is thrown when you attempt to use a dispatch object after the dispatch system has been shutdown in OSGi.
 

Package org.fusesource.hawtdispatch Description

HawtDispatch

HawtDispatch is an abstract model for expressing concurrency via simple but powerful API.

At the core, HawtDispatch provides serial FIFO queues to which runnables may be submitted. Runnables submitted to these dispatch queues are invoked on a pool of threads fully managed by the system. No guarantee is made regarding which thread a runnable will be invoked on; however, it is guaranteed that only one runnable submitted to the FIFO dispatch queue will be invoked at a time.

HawtDispatch also provides dispatch sources to handle converting events like NIO Socket readiness events into callbacks to runnables executed on the dispatch queues.



Copyright © 2010-2014 FuseSource, Corp.. All Rights Reserved.