Uses of Interface
org.fusesource.hawtdispatch.DispatchQueue

Packages that use DispatchQueue

Package	Description
org.fusesource.hawtdispatch	HawtDispatch
org.fusesource.hawtdispatch.internal
org.fusesource.hawtdispatch.internal.util
org.fusesource.hawtdispatch.transport

Uses of DispatchQueue in org.fusesource.hawtdispatch

Fields in org.fusesource.hawtdispatch declared as DispatchQueue

Modifier and Type	Field and Description
(package private) DispatchQueue	AggregatingExecutor.queue
DispatchQueue	Metrics.queue The dispatch queue associated with the metrics collected.

Methods in org.fusesource.hawtdispatch that return DispatchQueue

Modifier and Type	Method and Description
static DispatchQueue	Dispatch.createQueue() Creates a new serial dispatch queue to which runnable objects may be submitted.
static DispatchQueue	Dispatch.createQueue(java.lang.String label) Creates a new serial dispatch queue to which runnable objects may be submitted.
DispatchQueue	Dispatcher.createQueue(java.lang.String label) Creates a new serial dispatch queue to which runnable objects may be submitted.
DispatchQueue	DispatchQueue.createQueue(java.lang.String label) Creates a new serial dispatch queue with this queue set as it's target queue.
static DispatchQueue	Dispatch.getCurrentQueue() Returns the queue on which the currently executing runnable is running.
DispatchQueue	Dispatcher.getCurrentQueue() Returns the queue on which the currently executing runnable is running.
static DispatchQueue	Dispatch.getCurrentThreadQueue()
DispatchQueue	Dispatcher.getCurrentThreadQueue()
static DispatchQueue	Dispatch.getGlobalQueue() Returns the global concurrent queue of default priority.
DispatchQueue	Dispatcher.getGlobalQueue() Returns the global concurrent queue of default priority.
static DispatchQueue	Dispatch.getGlobalQueue(DispatchPriority priority) Returns a well-known global concurrent queue of a given priority level.
DispatchQueue	Dispatcher.getGlobalQueue(DispatchPriority priority) Returns a well-known global concurrent queue of a given priority level.
DispatchQueue	DispatchObject.getTargetQueue() Gets the target queue for this object.
static DispatchQueue[]	Dispatch.getThreadQueues(DispatchPriority priority)
DispatchQueue[]	Dispatcher.getThreadQueues(DispatchPriority priority)

Methods in org.fusesource.hawtdispatch with parameters of type DispatchQueue

Modifier and Type	Method and Description
static <T> T	DispatchQueueProxy.create(java.lang.Class<T> interfaceClass, T target, DispatchQueue queue) Create an asynchronous dispatch proxy to the target object via the dispatch queue.
static <T> T	DispatchQueueProxy.create(java.lang.ClassLoader classLoader, java.lang.Class<T> interfaceClass, T target, DispatchQueue queue) Create an asynchronous dispatch proxy to the target object via the dispatch queue.
static <Event,MergedEvent> CustomDispatchSource<Event,MergedEvent>	Dispatch.createSource(EventAggregator<Event,MergedEvent> aggregator, DispatchQueue queue) 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.
<Event,MergedEvent> CustomDispatchSource<Event,MergedEvent>	Dispatcher.createSource(EventAggregator<Event,MergedEvent> aggregator, DispatchQueue queue) 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.
static DispatchSource	Dispatch.createSource(java.nio.channels.SelectableChannel channel, int interestOps, DispatchQueue queue) Creates a new DispatchSource to monitor SelectableChannel objects and automatically submit a handler runnable to a dispatch queue in response to events.
DispatchSource	Dispatcher.createSource(java.nio.channels.SelectableChannel channel, int interestOps, DispatchQueue queue) Creates a new DispatchSource to monitor SelectableChannel objects and automatically submit a handler runnable to a dispatch queue in response to events.
void	DispatchObject.setTargetQueue(DispatchQueue queue) Sets the target queue for this object.

Constructors in org.fusesource.hawtdispatch with parameters of type DispatchQueue

Constructor and Description
AggregatingExecutor(DispatchQueue queue)

Uses of DispatchQueue in org.fusesource.hawtdispatch.internal

Subinterfaces of DispatchQueue in org.fusesource.hawtdispatch.internal

Modifier and Type	Interface and Description
interface	HawtDispatchQueue

Classes in org.fusesource.hawtdispatch.internal that implement DispatchQueue

Modifier and Type	Class and Description
class	GlobalDispatchQueue
class	SerialDispatchQueue
class	ThreadDispatchQueue

Fields in org.fusesource.hawtdispatch.internal declared as DispatchQueue

Modifier and Type	Field and Description
private DispatchQueue	ActiveMetricsCollector.queue
(package private) DispatchQueue	NioDispatchSource.selectorQueue
(package private) DispatchQueue	TimerThread.TimerRequest.target

Methods in org.fusesource.hawtdispatch.internal that return DispatchQueue

Modifier and Type	Method and Description
DispatchQueue	SerialDispatchQueue.createQueue(java.lang.String label)
DispatchQueue	GlobalDispatchQueue.createQueue(java.lang.String label)
DispatchQueue	ThreadDispatchQueue.createQueue(java.lang.String label)
DispatchQueue	HawtDispatcher.getCurrentQueue()
DispatchQueue	HawtDispatcher.getGlobalQueue()
(package private) DispatchQueue[]	GlobalDispatchQueue.getThreadQueues()
DispatchQueue[]	HawtDispatcher.getThreadQueues(DispatchPriority priority)
private static DispatchQueue	NioDispatchSource.pickThreadQueue(HawtDispatcher dispatcher, DispatchQueue targetQueue)

Methods in org.fusesource.hawtdispatch.internal with parameters of type DispatchQueue

Modifier and Type	Method and Description
void	TimerThread.addAbsolute(Task task, DispatchQueue target, long time, java.util.concurrent.TimeUnit unit)
void	TimerThread.addRelative(Task task, DispatchQueue target, long delay, java.util.concurrent.TimeUnit unit)
<Event,MergedEvent> CustomDispatchSource<Event,MergedEvent>	HawtDispatcher.createSource(EventAggregator<Event,MergedEvent> aggregator, DispatchQueue queue)
DispatchSource	HawtDispatcher.createSource(java.nio.channels.SelectableChannel channel, int interestOps, DispatchQueue queue)
private boolean	NioDispatchSource.isCurrent(DispatchQueue q)
private static DispatchQueue	NioDispatchSource.pickThreadQueue(HawtDispatcher dispatcher, DispatchQueue targetQueue)
private void	NioDispatchSource.register_on(DispatchQueue queue)
void	NioDispatchSource.setTargetQueue(DispatchQueue next)
void	GlobalDispatchQueue.setTargetQueue(DispatchQueue queue)
void	AbstractDispatchObject.setTargetQueue(DispatchQueue next)
void	ThreadDispatchQueue.setTargetQueue(DispatchQueue queue)
void	TimerThread.shutdown(Task onShutdown, DispatchQueue target)

Constructors in org.fusesource.hawtdispatch.internal with parameters of type DispatchQueue

Constructor and Description
ActiveMetricsCollector(DispatchQueue queue)
HawtCustomDispatchSource(HawtDispatcher dispatcher, EventAggregator<Event,MergedEvent> aggregator, DispatchQueue queue)
NioDispatchSource(HawtDispatcher dispatcher, java.nio.channels.SelectableChannel channel, int interestOps, DispatchQueue targetQueue)

Uses of DispatchQueue in org.fusesource.hawtdispatch.internal.util

Methods in org.fusesource.hawtdispatch.internal.util with parameters of type DispatchQueue

Modifier and Type	Method and Description
static void	QueueSupport.dispatchApply(DispatchQueue queue, int iterations, java.lang.Runnable runnable)
static void	QueueSupport.dispatchApply(DispatchQueue queue, int iterations, Task task)
static Task	RunnableSupport.runAfter(DispatchQueue queue, java.lang.Runnable runnable, int count)
static Task	RunnableSupport.runAfter(DispatchQueue queue, Task task, int count)
static Task	RunnableSupport.runOnceAfter(DispatchQueue queue, java.lang.Runnable runnable, int count)
static Task	RunnableSupport.runOnceAfter(DispatchQueue queue, Task task, int count)

Uses of DispatchQueue in org.fusesource.hawtdispatch.transport

Fields in org.fusesource.hawtdispatch.transport declared as DispatchQueue

Modifier and Type	Field and Description
protected DispatchQueue	UdpTransport.dispatchQueue
(package private) DispatchQueue	PipeTransportServer.dispatchQueue
protected DispatchQueue	TcpTransportServer.dispatchQueue
private DispatchQueue	PipeTransport.dispatchQueue
private DispatchQueue	UdpTransportServer.dispatchQueue
protected DispatchQueue	TcpTransport.dispatchQueue

Methods in org.fusesource.hawtdispatch.transport that return DispatchQueue

Modifier and Type	Method and Description
DispatchQueue	UdpTransport.getDispatchQueue()
protected abstract DispatchQueue	ServiceBase.getDispatchQueue()
DispatchQueue	TransportFilter.getDispatchQueue()
DispatchQueue	PipeTransportServer.getDispatchQueue()
DispatchQueue	TcpTransportServer.getDispatchQueue()
DispatchQueue	Transport.getDispatchQueue() Returns the dispatch queue used by the transport
DispatchQueue	PipeTransport.getDispatchQueue()
DispatchQueue	UdpTransportServer.getDispatchQueue()
DispatchQueue	TcpTransport.getDispatchQueue()
DispatchQueue	TransportServer.getDispatchQueue() Returns the dispatch queue used by the transport

Methods in org.fusesource.hawtdispatch.transport with parameters of type DispatchQueue

Modifier and Type	Method and Description
void	UdpTransport.setDispatchQueue(DispatchQueue queue)
void	TransportFilter.setDispatchQueue(DispatchQueue queue)
void	PipeTransportServer.setDispatchQueue(DispatchQueue queue)
void	TcpTransportServer.setDispatchQueue(DispatchQueue dispatchQueue)
void	Transport.setDispatchQueue(DispatchQueue queue) Sets the dispatch queue used by the transport
void	PipeTransport.setDispatchQueue(DispatchQueue queue)
void	UdpTransportServer.setDispatchQueue(DispatchQueue dispatchQueue)
void	TcpTransport.setDispatchQueue(DispatchQueue queue)
void	TransportServer.setDispatchQueue(DispatchQueue queue) Sets the dispatch queue used by the transport