Uses of Class
org.fusesource.hawtdispatch.Task

Packages that use Task

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

Uses of Task in org.fusesource.hawtdispatch

Subclasses of Task in org.fusesource.hawtdispatch

Modifier and Type	Class and Description
class	TaskWrapper

Fields in org.fusesource.hawtdispatch declared as Task

Modifier and Type	Field and Description
private Task	BaseRetained.disposer
static Task	Dispatch.NOOP A Runnable task that does nothing.

Methods in org.fusesource.hawtdispatch that return Task

Modifier and Type	Method and Description
Task	BaseRetained.getDisposer()

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

Modifier and Type	Method and Description
void	DispatchQueue.execute(Task task) Submits a task for asynchronous execution on a dispatch queue.
void	DispatchQueue.executeAfter(long delay, java.util.concurrent.TimeUnit unit, Task task) Schedule a task for execution on a given queue at a specified time.
void	DispatchSource.setCancelHandler(Task task) Sets the cancellation handler task for the given dispatch source.
void	BaseRetained.setDisposer(Task disposer) Adds a disposer runnable that is executed once the object is disposed.
void	DispatchSource.setEventHandler(Task task) Sets the event handler task of this dispatch source.

Uses of Task in org.fusesource.hawtdispatch.internal

Subclasses of Task in org.fusesource.hawtdispatch.internal

Modifier and Type	Class and Description
class	AbstractDispatchObject
class	BaseSuspendable
class	HawtCustomDispatchSource<Event,MergedEvent>
class	NioDispatchSource Implements the DispatchSource interface.
class	SerialDispatchQueue

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

Modifier and Type	Field and Description
(package private) Task	NioDispatchSource.cancelHandler
private Task	HawtCustomDispatchSource.cancelHandler
(package private) Task	NioDispatchSource.eventHandler
private Task	HawtCustomDispatchSource.eventHandler
(package private) Task	TimerThread.TimerRequest.task
private Task	NioDispatchSource.updateInterestTask

Fields in org.fusesource.hawtdispatch.internal with type parameters of type Task

Modifier and Type	Field and Description
protected java.util.concurrent.ConcurrentLinkedQueue<Task>	SerialDispatchQueue.externalQueue
private java.util.LinkedList<Task>	SerialDispatchQueue.localQueue
(package private) java.util.LinkedList<Task>	ThreadDispatchQueue.localTasks
(package private) java.util.concurrent.ConcurrentLinkedQueue<Task>	ThreadDispatchQueue.sharedTasks
private java.util.LinkedList<Task>	SerialDispatchQueue.sourceQueue
private java.util.LinkedList<Task>	ThreadDispatchQueue.sourceQueue

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

Modifier and Type	Method and Description
Task	ThreadDispatchQueue.poll()
Task	InactiveMetricsCollector.track(Task runnable)
abstract Task	MetricsCollector.track(Task runnable)
Task	ActiveMetricsCollector.track(Task runnable)

Methods in org.fusesource.hawtdispatch.internal that return types with arguments of type Task

Modifier and Type	Method and Description
java.util.LinkedList<Task>	HawtDispatchQueue.getSourceQueue()
java.util.LinkedList<Task>	SerialDispatchQueue.getSourceQueue()
java.util.LinkedList<Task>	GlobalDispatchQueue.getSourceQueue()
java.util.LinkedList<Task>	ThreadDispatchQueue.getSourceQueue()

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

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)
private void	SerialDispatchQueue.enqueue(Task runnable)
void	WorkerPool.execute(Task runnable)
void	SerialDispatchQueue.execute(Task task)
void	GlobalDispatchQueue.execute(Task task)
void	ThreadDispatchQueue.execute(Task task)
void	SerialDispatchQueue.executeAfter(long delay, java.util.concurrent.TimeUnit unit, Task task)
void	GlobalDispatchQueue.executeAfter(long delay, java.util.concurrent.TimeUnit unit, Task task)
void	ThreadDispatchQueue.executeAfter(long delay, java.util.concurrent.TimeUnit unit, Task task)
void	NioDispatchSource.setCancelHandler(Task cancelHandler)
void	HawtCustomDispatchSource.setCancelHandler(Task cancelHandler)
void	NioDispatchSource.setEventHandler(Task eventHandler)
void	HawtCustomDispatchSource.setEventHandler(Task eventHandler)
void	TimerThread.shutdown(Task onShutdown, DispatchQueue target)
Task	InactiveMetricsCollector.track(Task runnable)
abstract Task	MetricsCollector.track(Task runnable)
Task	ActiveMetricsCollector.track(Task runnable)

Uses of Task in org.fusesource.hawtdispatch.internal.pool

Fields in org.fusesource.hawtdispatch.internal.pool with type parameters of type Task

Modifier and Type	Field and Description
(package private) java.util.concurrent.ConcurrentLinkedQueue<Task>	SimplePool.tasks

Methods in org.fusesource.hawtdispatch.internal.pool with parameters of type Task

Modifier and Type	Method and Description
void	SimplePool.execute(Task runnable)

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

Subclasses of Task in org.fusesource.hawtdispatch.internal.util

Modifier and Type	Class and Description
class	RunnableCountDownLatch

Fields in org.fusesource.hawtdispatch.internal.util declared as Task

Modifier and Type	Field and Description
private static Task	RunnableSupport.NO_OP

Methods in org.fusesource.hawtdispatch.internal.util that return Task

Modifier and Type	Method and Description
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.runAfter(java.lang.Runnable runnable, int count)
static Task	RunnableSupport.runAfter(Task runnable, int count)
static Task	RunnableSupport.runNoop()
static Task	RunnableSupport.runOnceAfter(DispatchQueue queue, java.lang.Runnable runnable, int count)
static Task	RunnableSupport.runOnceAfter(DispatchQueue queue, Task task, int count)
static Task	RunnableSupport.runOnceAfter(java.lang.Runnable runnable, int count)
static Task	RunnableSupport.runOnceAfter(Task runnable, int count)

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

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

Uses of Task in org.fusesource.hawtdispatch.transport

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

Modifier and Type	Field and Description
private Task	UdpTransport.CANCEL_HANDLER
private Task	TcpTransport.CANCEL_HANDLER
(package private) Task	HeartBeatMonitor.onDead
(package private) Task	UdpTransport.onDispose
(package private) Task	HeartBeatMonitor.onKeepAlive

Fields in org.fusesource.hawtdispatch.transport with type parameters of type Task

Modifier and Type	Field and Description
(package private) java.util.LinkedList<Task>	ServiceBase.CallbackSupport.callbacks
private java.util.LinkedList<Task>	UdpTransport.CANCELING.runnables
private java.util.LinkedList<Task>	TcpTransport.CANCELING.runnables

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

Modifier and Type	Method and Description
(package private) Task	UdpTransport.CONNECTED.createDisconnectTask()
(package private) Task	TcpTransport.CONNECTED.createDisconnectTask()
Task	HeartBeatMonitor.getOnDead()
Task	HeartBeatMonitor.getOnKeepAlive()

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

Modifier and Type	Method and Description
void	UdpTransport._start(Task onCompleted)
protected abstract void	ServiceBase._start(Task onCompleted)
protected void	UdpTransportServer._start(Task onCompleted)
void	TcpTransport._start(Task onCompleted)
void	UdpTransport._stop(Task onCompleted)
protected abstract void	ServiceBase._stop(Task onCompleted)
protected void	UdpTransportServer._stop(Task onCompleted)
void	TcpTransport._stop(Task onCompleted)
(package private) void	UdpTransport.CANCELING.add(Task onCompleted)
(package private) void	ServiceBase.CallbackSupport.add(Task r)
(package private) void	TcpTransport.CANCELING.add(Task onCompleted)
(package private) void	UdpTransport.SocketState.onStop(Task onCompleted)
(package private) void	UdpTransport.CONNECTING.onStop(Task onCompleted)
(package private) void	UdpTransport.CONNECTED.onStop(Task onCompleted)
(package private) void	UdpTransport.CANCELING.onStop(Task onCompleted)
(package private) void	UdpTransport.CANCELED.onStop(Task onCompleted)
(package private) void	TcpTransport.SocketState.onStop(Task onCompleted)
(package private) void	TcpTransport.CONNECTING.onStop(Task onCompleted)
(package private) void	TcpTransport.CONNECTED.onStop(Task onCompleted)
(package private) void	TcpTransport.CANCELING.onStop(Task onCompleted)
(package private) void	TcpTransport.CANCELED.onStop(Task onCompleted)
private void	HeartBeatMonitor.schedule(short session, long interval, Task func)
void	HeartBeatMonitor.setOnDead(Task onDead)
void	HeartBeatMonitor.setOnKeepAlive(Task onKeepAlive)
void	ServiceBase.start(Task onCompleted)
void	TransportFilter.start(Task onComplete)
void	PipeTransportServer.start(Task onCompleted)
void	TcpTransportServer.start(Task onCompleted)
void	Transport.start(Task onComplete) Starts the service.
void	PipeTransport.start(Task onCompleted)
void	SslTransportServer.start(Task onCompleted)
void	TransportServer.start(Task onComplete) Starts the service.
void	ServiceBase.stop(Task onCompleted)
void	TransportFilter.stop(Task onComplete)
void	PipeTransportServer.stop(Task onCompleted)
void	TcpTransportServer.stop(Task onCompleted)
void	Transport.stop(Task onComplete) Stops the service.
void	PipeTransport.stop(Task onCompleted)
void	TransportServer.stop(Task onComplete) Stops the service.