Package org.apache.http.nio.pool
Class AbstractNIOConnPool<T,C,E extends org.apache.http.pool.PoolEntry<T,C>>
java.lang.Object
org.apache.http.nio.pool.AbstractNIOConnPool<T,C,E>
- Type Parameters:
T
- routeC
- connection objectE
- pool entry
- All Implemented Interfaces:
org.apache.http.pool.ConnPool<T,
,E> org.apache.http.pool.ConnPoolControl<T>
- Direct Known Subclasses:
BasicNIOConnPool
@Contract(threading=SAFE_CONDITIONAL)
public abstract class AbstractNIOConnPool<T,C,E extends org.apache.http.pool.PoolEntry<T,C>>
extends Object
implements org.apache.http.pool.ConnPool<T,E>, org.apache.http.pool.ConnPoolControl<T>
Abstract non-blocking connection pool.
- Since:
- 4.2
-
Constructor Summary
ConstructorsConstructorDescriptionAbstractNIOConnPool
(ConnectingIOReactor ioReactor, NIOConnFactory<T, C> connFactory, int defaultMaxPerRoute, int maxTotal) Deprecated.AbstractNIOConnPool
(ConnectingIOReactor ioReactor, NIOConnFactory<T, C> connFactory, SocketAddressResolver<T> addressResolver, int defaultMaxPerRoute, int maxTotal) -
Method Summary
Modifier and TypeMethodDescriptionvoid
void
protected abstract E
createEntry
(T route, C conn) protected void
enumAvailable
(org.apache.http.pool.PoolEntryCallback<T, C> callback) Enumerates all available connections.protected void
enumEntries
(Iterator<E> it, org.apache.http.pool.PoolEntryCallback<T, C> callback) Deprecated.(4.3.2)protected void
enumLeased
(org.apache.http.pool.PoolEntryCallback<T, C> callback) Enumerates all leased connections.int
int
getMaxPerRoute
(T route) int
Returns snapshot of all knows routesorg.apache.http.pool.PoolStats
org.apache.http.pool.PoolStats
boolean
lease
(T route, Object state, long connectTimeout, long leaseTimeout, TimeUnit timeUnit, org.apache.http.concurrent.FutureCallback<E> callback) lease
(T route, Object state, long connectTimeout, TimeUnit timeUnit, org.apache.http.concurrent.FutureCallback<E> callback) protected void
protected void
protected void
void
protected void
requestCancelled
(SessionRequest request) protected void
requestCompleted
(SessionRequest request) protected void
requestFailed
(SessionRequest request) protected void
requestTimeout
(SessionRequest request) protected SocketAddress
resolveLocalAddress
(T route) Deprecated.(4.3) useSocketAddressResolver
protected SocketAddress
resolveRemoteAddress
(T route) Deprecated.(4.3) useSocketAddressResolver
void
setDefaultMaxPerRoute
(int max) void
setMaxPerRoute
(T route, int max) void
setMaxTotal
(int max) void
shutdown
(long waitMs) toString()
void
-
Constructor Details
-
AbstractNIOConnPool
@Deprecated public AbstractNIOConnPool(ConnectingIOReactor ioReactor, NIOConnFactory<T, C> connFactory, int defaultMaxPerRoute, int maxTotal) -
AbstractNIOConnPool
public AbstractNIOConnPool(ConnectingIOReactor ioReactor, NIOConnFactory<T, C> connFactory, SocketAddressResolver<T> addressResolver, int defaultMaxPerRoute, int maxTotal) - Since:
- 4.3
-
-
Method Details
-
resolveRemoteAddress
Deprecated.(4.3) useSocketAddressResolver
-
resolveLocalAddress
Deprecated.(4.3) useSocketAddressResolver
-
createEntry
-
onLease
- Since:
- 4.3
-
onRelease
- Since:
- 4.3
-
onReuse
- Since:
- 4.4
-
isShutdown
public boolean isShutdown() -
shutdown
- Throws:
IOException
-
lease
-
lease
public Future<E> lease(T route, Object state, long connectTimeout, long leaseTimeout, TimeUnit timeUnit, org.apache.http.concurrent.FutureCallback<E> callback) - Since:
- 4.3
-
lease
-
lease
-
release
-
validatePendingRequests
public void validatePendingRequests() -
requestCompleted
-
requestCancelled
-
requestFailed
-
requestTimeout
-
setMaxTotal
public void setMaxTotal(int max) - Specified by:
setMaxTotal
in interfaceorg.apache.http.pool.ConnPoolControl<T>
-
getMaxTotal
public int getMaxTotal()- Specified by:
getMaxTotal
in interfaceorg.apache.http.pool.ConnPoolControl<T>
-
setDefaultMaxPerRoute
public void setDefaultMaxPerRoute(int max) - Specified by:
setDefaultMaxPerRoute
in interfaceorg.apache.http.pool.ConnPoolControl<T>
-
getDefaultMaxPerRoute
public int getDefaultMaxPerRoute()- Specified by:
getDefaultMaxPerRoute
in interfaceorg.apache.http.pool.ConnPoolControl<T>
-
setMaxPerRoute
- Specified by:
setMaxPerRoute
in interfaceorg.apache.http.pool.ConnPoolControl<T>
-
getMaxPerRoute
- Specified by:
getMaxPerRoute
in interfaceorg.apache.http.pool.ConnPoolControl<T>
-
getTotalStats
public org.apache.http.pool.PoolStats getTotalStats()- Specified by:
getTotalStats
in interfaceorg.apache.http.pool.ConnPoolControl<T>
-
getStats
- Specified by:
getStats
in interfaceorg.apache.http.pool.ConnPoolControl<T>
-
getRoutes
Returns snapshot of all knows routes- Since:
- 4.4
-
enumAvailable
Enumerates all available connections.- Since:
- 4.3
-
enumLeased
Enumerates all leased connections.- Since:
- 4.3
-
enumEntries
@Deprecated protected void enumEntries(Iterator<E> it, org.apache.http.pool.PoolEntryCallback<T, C> callback) Deprecated.(4.3.2) -
closeIdle
-
closeExpired
public void closeExpired() -
toString
-
AbstractNIOConnPool(ConnectingIOReactor, NIOConnFactory, SocketAddressResolver, int, int)