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 | Class and Description |
---|---|
class |
TaskWrapper
|
Modifier and Type | Field and Description |
---|---|
static Task |
Dispatch.NOOP
A Runnable task that does nothing.
|
Modifier and Type | Method and Description |
---|---|
Task |
BaseRetained.getDisposer() |
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,
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.
|
Modifier and Type | Method and Description |
---|---|
Task |
HeartBeatMonitor.getOnDead() |
Task |
HeartBeatMonitor.getOnKeepAlive() |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
ServiceBase._start(Task onCompleted) |
void |
TcpTransport._start(Task onCompleted) |
protected void |
UdpTransportServer._start(Task onCompleted) |
void |
UdpTransport._start(Task onCompleted) |
protected abstract void |
ServiceBase._stop(Task onCompleted) |
void |
TcpTransport._stop(Task onCompleted) |
protected void |
UdpTransportServer._stop(Task onCompleted) |
void |
UdpTransport._stop(Task onCompleted) |
void |
HeartBeatMonitor.setOnDead(Task onDead) |
void |
HeartBeatMonitor.setOnKeepAlive(Task onKeepAlive) |
void |
TcpTransportServer.start(Task onCompleted) |
void |
TransportServer.start(Task onComplete)
Starts the service.
|
void |
TransportFilter.start(Task onComplete) |
void |
SslTransportServer.start(Task onCompleted) |
void |
ServiceBase.start(Task onCompleted) |
void |
PipeTransport.start(Task onCompleted) |
void |
Transport.start(Task onComplete)
Starts the service.
|
void |
PipeTransportServer.start(Task onCompleted) |
void |
TcpTransportServer.stop(Task onCompleted) |
void |
TransportServer.stop(Task onComplete)
Stops the service.
|
void |
TransportFilter.stop(Task onComplete) |
void |
ServiceBase.stop(Task onCompleted) |
void |
PipeTransport.stop(Task onCompleted) |
void |
Transport.stop(Task onComplete)
Stops the service.
|
void |
PipeTransportServer.stop(Task onCompleted) |
Copyright © 2010–2017 FuseSource, Corp.. All rights reserved.