Package | Description |
---|---|
org.fusesource.hawtdispatch |
HawtDispatch
HawtDispatch is an abstract model for expressing concurrency via simple but
powerful API.
|
org.fusesource.hawtdispatch.transport |
Modifier and Type | Field and Description |
---|---|
DispatchQueue |
Metrics.queue
The dispatch queue associated with the metrics collected.
|
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(String label)
Creates a new serial dispatch queue to which runnable objects may be submitted.
|
DispatchQueue |
Dispatcher.createQueue(String label)
Creates a new serial dispatch queue to which runnable objects may be submitted.
|
DispatchQueue |
DispatchQueue.createQueue(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) |
Modifier and Type | Method and Description |
---|---|
static <T> T |
DispatchQueueProxy.create(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(ClassLoader classLoader,
Class<T> interfaceClass,
T target,
DispatchQueue queue)
Create an asynchronous dispatch proxy to the target object via the dispatch queue.
|
static <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> |
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(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(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.
|
Constructor and Description |
---|
AggregatingExecutor(DispatchQueue queue) |
Modifier and Type | Field and Description |
---|---|
protected DispatchQueue |
TcpTransportServer.dispatchQueue |
protected DispatchQueue |
TcpTransport.dispatchQueue |
protected DispatchQueue |
UdpTransport.dispatchQueue |
Modifier and Type | Method and Description |
---|---|
DispatchQueue |
TcpTransportServer.getDispatchQueue() |
DispatchQueue |
TransportServer.getDispatchQueue()
Returns the dispatch queue used by the transport
|
DispatchQueue |
TransportFilter.getDispatchQueue() |
protected abstract DispatchQueue |
ServiceBase.getDispatchQueue() |
DispatchQueue |
TcpTransport.getDispatchQueue() |
DispatchQueue |
PipeTransport.getDispatchQueue() |
DispatchQueue |
UdpTransportServer.getDispatchQueue() |
DispatchQueue |
Transport.getDispatchQueue()
Returns the dispatch queue used by the transport
|
DispatchQueue |
UdpTransport.getDispatchQueue() |
DispatchQueue |
PipeTransportServer.getDispatchQueue() |
Modifier and Type | Method and Description |
---|---|
void |
TcpTransportServer.setDispatchQueue(DispatchQueue dispatchQueue) |
void |
TransportServer.setDispatchQueue(DispatchQueue queue)
Sets the dispatch queue used by the transport
|
void |
TransportFilter.setDispatchQueue(DispatchQueue queue) |
void |
TcpTransport.setDispatchQueue(DispatchQueue queue) |
void |
PipeTransport.setDispatchQueue(DispatchQueue queue) |
void |
UdpTransportServer.setDispatchQueue(DispatchQueue dispatchQueue) |
void |
Transport.setDispatchQueue(DispatchQueue queue)
Sets the dispatch queue used by the transport
|
void |
UdpTransport.setDispatchQueue(DispatchQueue queue) |
void |
PipeTransportServer.setDispatchQueue(DispatchQueue queue) |
Copyright © 2010–2017 FuseSource, Corp.. All rights reserved.