| Package | Description |
|---|---|
| org.apache.http.impl.nio.reactor |
Default implementation of event driven network communication APIs
based on Java NIO.
|
| Modifier and Type | Method | Description |
|---|---|---|
protected abstract void |
AbstractMultiworkerIOReactor.cancelRequests() |
Triggered to cancel pending session requests.
|
protected void |
DefaultConnectingIOReactor.cancelRequests() |
|
protected void |
DefaultListeningIOReactor.cancelRequests() |
|
protected void |
AbstractIOReactor.closeActiveChannels() |
Closes out all active channels registered with the selector of
this I/O reactor.
|
protected void |
AbstractIOReactor.closeNewChannels() |
Closes out all new channels pending registration with the selector of
this I/O reactor.
|
protected void |
AbstractIOReactor.execute() |
Activates the I/O reactor.
|
void |
AbstractMultiworkerIOReactor.execute(IOEventDispatch eventDispatch) |
Activates the main I/O reactor as well as all worker I/O reactors.
|
void |
BaseIOReactor.execute(IOEventDispatch eventDispatch) |
Activates the I/O reactor.
|
void |
AbstractIOReactor.hardShutdown() |
Attempts force-shutdown of this I/O reactor.
|
protected abstract void |
AbstractMultiworkerIOReactor.processEvents(int count) |
Triggered to process I/O events registered by the main
Selector. |
protected void |
DefaultConnectingIOReactor.processEvents(int readyCount) |
|
protected void |
DefaultListeningIOReactor.processEvents(int readyCount) |
|
void |
AbstractIOReactor.shutdown() |
|
void |
AbstractIOReactor.shutdown(long gracePeriod) |
| Constructor | Description |
|---|---|
AbstractIOReactor(long selectTimeout) |
Creates new AbstractIOReactor instance.
|
AbstractIOReactor(long selectTimeout,
boolean interestOpsQueueing) |
Creates new AbstractIOReactor instance.
|
AbstractMultiworkerIOReactor() |
Creates an instance of AbstractMultiworkerIOReactor with default configuration.
|
AbstractMultiworkerIOReactor(int workerCount,
java.util.concurrent.ThreadFactory threadFactory,
org.apache.http.params.HttpParams params) |
Deprecated.
|
AbstractMultiworkerIOReactor(IOReactorConfig config,
java.util.concurrent.ThreadFactory threadFactory) |
Creates an instance of AbstractMultiworkerIOReactor with the given configuration.
|
BaseIOReactor(long selectTimeout) |
Creates new BaseIOReactor instance.
|
BaseIOReactor(long selectTimeout,
boolean interestOpsQueueing) |
Creates new BaseIOReactor instance.
|
DefaultConnectingIOReactor() |
Creates an instance of DefaultConnectingIOReactor with default configuration.
|
DefaultConnectingIOReactor(int workerCount,
java.util.concurrent.ThreadFactory threadFactory,
org.apache.http.params.HttpParams params) |
Deprecated.
|
DefaultConnectingIOReactor(int workerCount,
org.apache.http.params.HttpParams params) |
Deprecated.
|
DefaultConnectingIOReactor(IOReactorConfig config) |
Creates an instance of DefaultConnectingIOReactor with the given configuration.
|
DefaultConnectingIOReactor(IOReactorConfig config,
java.util.concurrent.ThreadFactory threadFactory) |
Creates an instance of DefaultConnectingIOReactor with the given configuration.
|
DefaultListeningIOReactor() |
Creates an instance of DefaultListeningIOReactor with default configuration.
|
DefaultListeningIOReactor(int workerCount,
java.util.concurrent.ThreadFactory threadFactory,
org.apache.http.params.HttpParams params) |
Deprecated.
|
DefaultListeningIOReactor(int workerCount,
org.apache.http.params.HttpParams params) |
Deprecated.
|
DefaultListeningIOReactor(IOReactorConfig config) |
Creates an instance of DefaultListeningIOReactor with the given configuration.
|
DefaultListeningIOReactor(IOReactorConfig config,
java.util.concurrent.ThreadFactory threadFactory) |
Creates an instance of DefaultListeningIOReactor with the given configuration.
|