See: Description
Interface | Description |
---|---|
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 | Description |
---|---|
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 | Description |
---|---|
DispatchPriority |
Defines the supported global/concurrent queue priorities.
|
DispatchQueue.QueueType |
Defines the types of dispatch queues supported by the system.
|
Exception | Description |
---|---|
ShutdownException |
This exception is thrown when you attempt to use a dispatch object
after the dispatch system has been shutdown in OSGi.
|
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–2017 FuseSource, Corp.. All rights reserved.