Package | Description |
---|---|
org.apache.http.impl.nio.reactor |
Default implementation of event driven network communication APIs
based on Java NIO.
|
Modifier and Type | Method and Description |
---|---|
protected void |
DefaultListeningIOReactor.cancelRequests() |
protected void |
DefaultConnectingIOReactor.cancelRequests() |
protected abstract void |
AbstractMultiworkerIOReactor.cancelRequests()
Triggered to cancel pending session requests.
|
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 |
BaseIOReactor.execute(IOEventDispatch eventDispatch)
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 |
AbstractIOReactor.hardShutdown()
Attempts force-shutdown of this I/O reactor.
|
protected void |
DefaultListeningIOReactor.processEvents(int readyCount) |
protected void |
DefaultConnectingIOReactor.processEvents(int readyCount) |
protected abstract void |
AbstractMultiworkerIOReactor.processEvents(int count)
Triggered to process I/O events registered by the main
Selector . |
void |
AbstractIOReactor.shutdown() |
void |
AbstractIOReactor.shutdown(long gracePeriod) |
Constructor and 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,
ThreadFactory threadFactory,
HttpParams params)
|
AbstractMultiworkerIOReactor(IOReactorConfig config,
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,
HttpParams params)
Deprecated.
|
DefaultConnectingIOReactor(int workerCount,
ThreadFactory threadFactory,
HttpParams params)
Deprecated.
|
DefaultConnectingIOReactor(IOReactorConfig config)
Creates an instance of DefaultConnectingIOReactor with the given configuration.
|
DefaultConnectingIOReactor(IOReactorConfig config,
ThreadFactory threadFactory)
Creates an instance of DefaultConnectingIOReactor with the given configuration.
|
DefaultListeningIOReactor()
Creates an instance of DefaultListeningIOReactor with default configuration.
|
DefaultListeningIOReactor(int workerCount,
HttpParams params)
Deprecated.
|
DefaultListeningIOReactor(int workerCount,
ThreadFactory threadFactory,
HttpParams params)
Deprecated.
|
DefaultListeningIOReactor(IOReactorConfig config)
Creates an instance of DefaultListeningIOReactor with the given configuration.
|
DefaultListeningIOReactor(IOReactorConfig config,
ThreadFactory threadFactory)
Creates an instance of DefaultListeningIOReactor with the given configuration.
|
Copyright © 2005–2022 The Apache Software Foundation. All rights reserved.