A B C D E G H I L M N O P Q R S T V

A

AggregatingExecutor - Class in org.fusesource.hawtdispatch
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.
AggregatingExecutor(DispatchQueue) - Constructor for class org.fusesource.hawtdispatch.AggregatingExecutor
 
assertExecuting() - Method in interface org.fusesource.hawtdispatch.DispatchQueue
Asserts that the current dispatch queue is executing.
assertRetained() - Method in class org.fusesource.hawtdispatch.BaseRetained
Subclasses can use this method to validate that the object has not yet been released.

B

BaseRetained - Class in org.fusesource.hawtdispatch
Base class that implements the Retained interface.
BaseRetained() - Constructor for class org.fusesource.hawtdispatch.BaseRetained
 

C

cancel() - Method in interface org.fusesource.hawtdispatch.DispatchSource
Asynchronously cancel the dispatch source, preventing any further invocation of its event handler runnable.
create(Class<T>, T, DispatchQueue) - Static method in class org.fusesource.hawtdispatch.DispatchQueueProxy
Create an asynchronous dispatch proxy to the target object via the dispatch queue.
create(ClassLoader, Class<T>, T, DispatchQueue) - Static method in class org.fusesource.hawtdispatch.DispatchQueueProxy
Create an asynchronous dispatch proxy to the target object via the dispatch queue.
createQueue(String) - Static method in class org.fusesource.hawtdispatch.Dispatch
Creates a new serial dispatch queue to which runnable objects may be submitted.
createQueue() - Static method in class org.fusesource.hawtdispatch.Dispatch
Creates a new serial dispatch queue to which runnable objects may be submitted.
createQueue(String) - Method in interface org.fusesource.hawtdispatch.Dispatcher
Creates a new serial dispatch queue to which runnable objects may be submitted.
createQueue(String) - Method in interface org.fusesource.hawtdispatch.DispatchQueue
Creates a new serial dispatch queue with this queue set as it's target queue.
createSource(SelectableChannel, int, DispatchQueue) - Static method in class org.fusesource.hawtdispatch.Dispatch
Creates a new DispatchSource to monitor SelectableChannel objects and automatically submit a handler runnable to a dispatch queue in response to events.
createSource(EventAggregator<Event, MergedEvent>, DispatchQueue) - Static method in class org.fusesource.hawtdispatch.Dispatch
Creates a new CustomDispatchSource to monitor events merged into the dispatch source and automatically submit a handler runnable to a dispatch queue in response to the events.
createSource(SelectableChannel, int, DispatchQueue) - Method in interface org.fusesource.hawtdispatch.Dispatcher
Creates a new DispatchSource to monitor SelectableChannel objects and automatically submit a handler runnable to a dispatch queue in response to events.
createSource(EventAggregator<Event, MergedEvent>, DispatchQueue) - Method in interface org.fusesource.hawtdispatch.Dispatcher
Creates a new CustomDispatchSource to monitor events merged into the dispatch source and automatically submit a handler runnable to a dispatch queue in response to the events.
CustomDispatchSource<Event,MergedEvent> - Interface in org.fusesource.hawtdispatch
A dispatch source that is used to coalesce multiple application generated events for later processing by the dispatch source event handler.

D

DEFAULT - Static variable in class org.fusesource.hawtdispatch.Dispatch
 
dequeued - Variable in class org.fusesource.hawtdispatch.Metrics
The number of runnable tasks that have been removed from the queue and executed.
Dispatch - Class in org.fusesource.hawtdispatch
The Dispatch class is used to get or create dispatch objects such as global queues, thread queues, serial queues, or dispatch sources.
Dispatch() - Constructor for class org.fusesource.hawtdispatch.Dispatch
 
Dispatcher - Interface in org.fusesource.hawtdispatch
The Dispatcher interface is used to get or create dispatch objects such as global queues, thread queues, serial queues, or dispatch sources.
DispatchObject - Interface in org.fusesource.hawtdispatch
Implemented by dispatch objects that can be configured with a target queue that it uses for executing the object's asynchronous tasks.
DispatchPriority - Enum in org.fusesource.hawtdispatch
Defines the supported global/concurrent queue priorities.
DispatchQueue - Interface in org.fusesource.hawtdispatch
Dispatch queues are lightweight objects to which runnable objects may be submitted for asynchronous execution and therefore are Executor objects.
DispatchQueue.QueueType - Enum in org.fusesource.hawtdispatch
Defines the types of dispatch queues supported by the system.
DispatchQueueProxy - Class in org.fusesource.hawtdispatch
This class creates proxy objects that allow you to easily service all method calls to an interface via a DispatchQueue.
DispatchQueueProxy() - Constructor for class org.fusesource.hawtdispatch.DispatchQueueProxy
 
DispatchSource - Interface in org.fusesource.hawtdispatch
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.
dispose() - Method in class org.fusesource.hawtdispatch.BaseRetained
This method will be called once the release retained reaches zero.

E

enqueued - Variable in class org.fusesource.hawtdispatch.Metrics
The number of runnable tasks queued.
EventAggregator<Event,MergedEvent> - Interface in org.fusesource.hawtdispatch
The EventAggregator interface is used by the CustomDispatchSource objects to handle coalescing data before passing it to the application.
EventAggregators - Class in org.fusesource.hawtdispatch
 
EventAggregators() - Constructor for class org.fusesource.hawtdispatch.EventAggregators
 
execute(Runnable) - Method in class org.fusesource.hawtdispatch.AggregatingExecutor
 
execute(Runnable) - Method in interface org.fusesource.hawtdispatch.DispatchQueue
Submits a runnable for asynchronous execution on a dispatch queue.
executeAfter(long, TimeUnit, Runnable) - Method in interface org.fusesource.hawtdispatch.DispatchQueue
Schedule a runnable for execution on a given queue at a specified time.

G

getCurrentQueue() - Static method in class org.fusesource.hawtdispatch.Dispatch
Returns the queue on which the currently executing runnable is running.
getCurrentQueue() - Method in interface org.fusesource.hawtdispatch.Dispatcher
Returns the queue on which the currently executing runnable is running.
getCurrentThreadQueue() - Static method in class org.fusesource.hawtdispatch.Dispatch
 
getCurrentThreadQueue() - Method in interface org.fusesource.hawtdispatch.Dispatcher
 
getData() - Method in interface org.fusesource.hawtdispatch.CustomDispatchSource
Returns pending data for the dispatch source.
getDisposer() - Method in class org.fusesource.hawtdispatch.BaseRetained
 
getGlobalQueue() - Static method in class org.fusesource.hawtdispatch.Dispatch
Returns the global concurrent queue of default priority.
getGlobalQueue(DispatchPriority) - Static method in class org.fusesource.hawtdispatch.Dispatch
Returns a well-known global concurrent queue of a given priority level.
getGlobalQueue() - Method in interface org.fusesource.hawtdispatch.Dispatcher
Returns the global concurrent queue of default priority.
getGlobalQueue(DispatchPriority) - Method in interface org.fusesource.hawtdispatch.Dispatcher
Returns a well-known global concurrent queue of a given priority level.
getLabel() - Method in interface org.fusesource.hawtdispatch.DispatchQueue
Returns the label of the queue.
getQueueType() - Method in interface org.fusesource.hawtdispatch.DispatchQueue
 
getTargetQueue() - Method in interface org.fusesource.hawtdispatch.DispatchObject
Gets the target queue for this object.
getThreadQueues(DispatchPriority) - Static method in class org.fusesource.hawtdispatch.Dispatch
 
getThreadQueues(DispatchPriority) - Method in interface org.fusesource.hawtdispatch.Dispatcher
 

H

hashSet() - Static method in class org.fusesource.hawtdispatch.EventAggregators
An EventAggregator that coalesces object data obtained via calls to CustomDispatchSource.merge(Object) into a hash set.
HIGH - Static variable in class org.fusesource.hawtdispatch.Dispatch
 

I

INTEGER_ADD - Static variable in class org.fusesource.hawtdispatch.EventAggregators
An EventAggregator that coalesces integer data obtained via calls to CustomDispatchSource.merge(Object).
INTEGER_OR - Static variable in class org.fusesource.hawtdispatch.EventAggregators
An EventAggregator that coalesces integer data obtained via calls to CustomDispatchSource.merge(Object).
isCanceled() - Method in interface org.fusesource.hawtdispatch.DispatchSource
 
isExecuting() - Method in interface org.fusesource.hawtdispatch.DispatchQueue
Returns true if this dispatch queue is executing the caller.
isSuspended() - Method in interface org.fusesource.hawtdispatch.Suspendable
 

L

linkedList() - Static method in class org.fusesource.hawtdispatch.EventAggregators
An EventAggregator that coalesces object data obtained via calls to CustomDispatchSource.merge(Object) into a linked list.
LONG_ADD - Static variable in class org.fusesource.hawtdispatch.EventAggregators
An EventAggregator that coalesces long data obtained via calls to CustomDispatchSource.merge(Object).
LONG_OR - Static variable in class org.fusesource.hawtdispatch.EventAggregators
An EventAggregator that coalesces long data obtained via calls to CustomDispatchSource.merge(Object).
LOW - Static variable in class org.fusesource.hawtdispatch.Dispatch
 

M

maxRunTimeNS - Variable in class org.fusesource.hawtdispatch.Metrics
The long amount of time a runnable task spent executing in nanoseconds.
maxWaitTimeNS - Variable in class org.fusesource.hawtdispatch.Metrics
The longest amount of time at runnable task spent waiting in the queue.
merge(Event) - Method in interface org.fusesource.hawtdispatch.CustomDispatchSource
Merges data into a dispatch source and submits its event handler runnable to its target queue.
mergeEvent(MergedEvent, Event) - Method in interface org.fusesource.hawtdispatch.EventAggregator
Merge the given event with the previous event values.
mergeEvents(MergedEvent, MergedEvent) - Method in interface org.fusesource.hawtdispatch.EventAggregator
Merge the given events with the previous event values.
metrics() - Static method in class org.fusesource.hawtdispatch.Dispatch
Used to get profiling metrics for all the queues currently being profiled.
metrics() - Method in interface org.fusesource.hawtdispatch.Dispatcher
Used to get profiling metrics for all the queues currently being profiled.
metrics() - Method in interface org.fusesource.hawtdispatch.DispatchQueue
Returns the usage metrics of this queue.
Metrics - Class in org.fusesource.hawtdispatch
Metrics() - Constructor for class org.fusesource.hawtdispatch.Metrics
 

N

NOOP - Static variable in class org.fusesource.hawtdispatch.Dispatch
A Runnable task that does nothing.

O

OrderedEventAggregator<Event,MergedEvent> - Interface in org.fusesource.hawtdispatch
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.
org.fusesource.hawtdispatch - package org.fusesource.hawtdispatch
HawtDispatch HawtDispatch is an abstract model for expressing concurrency via simple but powerful API.

P

profile(boolean) - Static method in class org.fusesource.hawtdispatch.Dispatch
If enabled then it enables profiling on the global queues and any newly created queues.
profile(boolean) - Method in interface org.fusesource.hawtdispatch.Dispatcher
If enabled then it enables profiling on the global queues and any newly created queues.
profile(boolean) - Method in interface org.fusesource.hawtdispatch.DispatchQueue
Enables or disables profiler metric tracking on the queue.

Q

queue - Variable in class org.fusesource.hawtdispatch.Metrics
The dispatch queue associated with the metrics collected.

R

release() - Method in class org.fusesource.hawtdispatch.BaseRetained
Decrement the reference count of this object.
release(int) - Method in class org.fusesource.hawtdispatch.BaseRetained
Decrements the reference count by n.
release() - Method in interface org.fusesource.hawtdispatch.Retained
Decrement the reference count of this object.
resume() - Method in class org.fusesource.hawtdispatch.AggregatingExecutor
 
resume() - Method in interface org.fusesource.hawtdispatch.Suspendable
Resumes the invocation of tasks on a dispatch object.
retain() - Method in class org.fusesource.hawtdispatch.BaseRetained
Increment the reference count of this object.
retain() - Method in interface org.fusesource.hawtdispatch.Retained
Increment the reference count of this object.
retained() - Method in class org.fusesource.hawtdispatch.BaseRetained
 
Retained - Interface in org.fusesource.hawtdispatch
Implemented by dispatch objects which use a reference counted life cycle.
retained() - Method in interface org.fusesource.hawtdispatch.Retained
 

S

setCancelHandler(Runnable) - Method in interface org.fusesource.hawtdispatch.DispatchSource
Sets the cancellation handler runnable for the given dispatch source.
setDisposer(Runnable) - Method in class org.fusesource.hawtdispatch.BaseRetained
Adds a disposer runnable that is executed once the object is disposed.
setEventHandler(Runnable) - Method in interface org.fusesource.hawtdispatch.DispatchSource
Sets the event handler runnable of this dispatch source.
setLabel(String) - Method in interface org.fusesource.hawtdispatch.DispatchQueue
Sets the label of the queue.
setTargetQueue(DispatchQueue) - Method in interface org.fusesource.hawtdispatch.DispatchObject
Sets the target queue for this object.
ShutdownException - Exception in org.fusesource.hawtdispatch
This exception is thrown when you attempt to use a dispatch object after the dispatch system has been shutdown in OSGi.
ShutdownException() - Constructor for exception org.fusesource.hawtdispatch.ShutdownException
 
ShutdownException(Throwable) - Constructor for exception org.fusesource.hawtdispatch.ShutdownException
 
ShutdownException(String, Throwable) - Constructor for exception org.fusesource.hawtdispatch.ShutdownException
 
ShutdownException(String) - Constructor for exception org.fusesource.hawtdispatch.ShutdownException
 
suspend() - Method in class org.fusesource.hawtdispatch.AggregatingExecutor
 
suspend() - Method in interface org.fusesource.hawtdispatch.Suspendable
Suspends the invocation of tasks on a dispatch object.
Suspendable - Interface in org.fusesource.hawtdispatch
Implemented by dispatch objects which can suspend the execution of dispatch tasks.

T

toString() - Method in class org.fusesource.hawtdispatch.Metrics
 
totalRunTimeNS - Variable in class org.fusesource.hawtdispatch.Metrics
The sum of all the time spent executing tasks in nanoseconds.
totalWaitTimeNS - Variable in class org.fusesource.hawtdispatch.Metrics
The sum of all the time that tasks spent waiting in the queue in nanoseconds.

V

valueOf(String) - Static method in enum org.fusesource.hawtdispatch.DispatchPriority
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.fusesource.hawtdispatch.DispatchQueue.QueueType
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.fusesource.hawtdispatch.DispatchPriority
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.fusesource.hawtdispatch.DispatchQueue.QueueType
Returns an array containing the constants of this enum type, in the order they are declared.

A B C D E G H I L M N O P Q R S T V

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