depends.org.apache.http.nio.pool

类 AbstractNIOConnPool<T,C,E extends PoolEntry<T,C>>

java.lang.Object

depends.org.apache.http.nio.pool.AbstractNIOConnPool<T,C,E>

类型参数:

T - route

C - connection object

E - pool entry

所有已实现的接口:

ConnPool<T,E>, ConnPoolControl<T>

直接已知子类:

BasicNIOConnPool

@ThreadSafe
public abstract class AbstractNIOConnPool<T,C,E extends PoolEntry<T,C>>
extends java.lang.Object
implements ConnPool<T,E>, ConnPoolControl<T>

Abstract non-blocking connection pool.

从以下版本开始:

4.2

构造器概要

构造器

构造器和说明
AbstractNIOConnPool(ConnectingIOReactor ioreactor, NIOConnFactory<T,C> connFactory, int defaultMaxPerRoute, int maxTotal) 已过时。 use AbstractNIOConnPool(ConnectingIOReactor, NIOConnFactory, SocketAddressResolver, int, int)
AbstractNIOConnPool(ConnectingIOReactor ioreactor, NIOConnFactory<T,C> connFactory, SocketAddressResolver<T> addressResolver, int defaultMaxPerRoute, int maxTotal)

方法概要

方法

限定符和类型	方法和说明
void	closeExpired()
void	closeIdle(long idletime, java.util.concurrent.TimeUnit tunit)
protected abstract E	createEntry(T route, C conn)
protected void	enumAvailable(PoolEntryCallback<T,C> callback) Enumerates all available connections.
protected void	enumEntries(java.util.Iterator<E> it, PoolEntryCallback<T,C> callback) 已过时。 (4.3.2)
protected void	enumLeased(PoolEntryCallback<T,C> callback) Enumerates all leased connections.
int	getDefaultMaxPerRoute()
int	getMaxPerRoute(T route)
int	getMaxTotal()
PoolStats	getStats(T route)
PoolStats	getTotalStats()
boolean	isShutdown()
java.util.concurrent.Future<E>	lease(T route, java.lang.Object state)
java.util.concurrent.Future<E>	lease(T route, java.lang.Object state, FutureCallback<E> callback) Attempts to lease a connection for the given route and with the given state from the pool.
java.util.concurrent.Future<E>	lease(T route, java.lang.Object state, long connectTimeout, long leaseTimeout, java.util.concurrent.TimeUnit tunit, FutureCallback<E> callback)
java.util.concurrent.Future<E>	lease(T route, java.lang.Object state, long connectTimeout, java.util.concurrent.TimeUnit tunit, FutureCallback<E> callback)
protected void	onLease(E entry)
protected void	onRelease(E entry)
void	release(E entry, boolean reusable) Releases the pool entry back to the pool.
protected void	requestCancelled(SessionRequest request)
protected void	requestCompleted(SessionRequest request)
protected void	requestFailed(SessionRequest request)
protected void	requestTimeout(SessionRequest request)
protected java.net.SocketAddress	resolveLocalAddress(T route) 已过时。 (4.3) use SocketAddressResolver
protected java.net.SocketAddress	resolveRemoteAddress(T route) 已过时。 (4.3) use SocketAddressResolver
void	setDefaultMaxPerRoute(int max)
void	setMaxPerRoute(T route, int max)
void	setMaxTotal(int max)
void	shutdown(long waitMs)
java.lang.String	toString()
void	validatePendingRequests()

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

构造器详细资料

AbstractNIOConnPool

@Deprecated
public AbstractNIOConnPool(ConnectingIOReactor ioreactor,
                              NIOConnFactory<T,C> connFactory,
                              int defaultMaxPerRoute,
                              int maxTotal)

已过时。 use AbstractNIOConnPool(ConnectingIOReactor, NIOConnFactory, SocketAddressResolver, int, int)

AbstractNIOConnPool

public AbstractNIOConnPool(ConnectingIOReactor ioreactor,
                   NIOConnFactory<T,C> connFactory,
                   SocketAddressResolver<T> addressResolver,
                   int defaultMaxPerRoute,
                   int maxTotal)

从以下版本开始:

4.3

方法详细资料

resolveRemoteAddress

@Deprecated
protected java.net.SocketAddress resolveRemoteAddress(T route)

已过时。 (4.3) use SocketAddressResolver

resolveLocalAddress

@Deprecated
protected java.net.SocketAddress resolveLocalAddress(T route)

已过时。 (4.3) use SocketAddressResolver

createEntry

protected abstract E createEntry(T route,
            C conn)

onLease

protected void onLease(E entry)

从以下版本开始:

4.3

onRelease

protected void onRelease(E entry)

从以下版本开始:

4.3

isShutdown

public boolean isShutdown()

shutdown

public void shutdown(long waitMs)
              throws java.io.IOException

抛出:

java.io.IOException

lease

public java.util.concurrent.Future<E> lease(T route,
                                   java.lang.Object state,
                                   long connectTimeout,
                                   java.util.concurrent.TimeUnit tunit,
                                   FutureCallback<E> callback)

lease

public java.util.concurrent.Future<E> lease(T route,
                                   java.lang.Object state,
                                   long connectTimeout,
                                   long leaseTimeout,
                                   java.util.concurrent.TimeUnit tunit,
                                   FutureCallback<E> callback)

从以下版本开始:

4.3

lease

public java.util.concurrent.Future<E> lease(T route,
                                   java.lang.Object state,
                                   FutureCallback<E> callback)

从接口复制的说明: ConnPool

Attempts to lease a connection for the given route and with the given state from the pool.

指定者:

lease 在接口中 ConnPool<T,E extends PoolEntry<T,C>>

参数:

route - route of the connection.

state - arbitrary object that represents a particular state (usually a security principal or a unique token identifying the user whose credentials have been used while establishing the connection). May be null.

callback - operation completion callback.

返回:

future for a leased pool entry.

lease

public java.util.concurrent.Future<E> lease(T route,
                                   java.lang.Object state)

release

public void release(E entry,
           boolean reusable)

从接口复制的说明: ConnPool

Releases the pool entry back to the pool.

指定者:

release 在接口中 ConnPool<T,E extends PoolEntry<T,C>>

参数:

entry - pool entry leased from the pool

reusable - flag indicating whether or not the released connection is in a consistent state and is safe for further use.

validatePendingRequests

public void validatePendingRequests()

requestCompleted

protected void requestCompleted(SessionRequest request)

requestCancelled

protected void requestCancelled(SessionRequest request)

requestFailed

protected void requestFailed(SessionRequest request)

requestTimeout

protected void requestTimeout(SessionRequest request)

setMaxTotal

public void setMaxTotal(int max)

指定者:

setMaxTotal 在接口中 ConnPoolControl<T>

getMaxTotal

public int getMaxTotal()

指定者:

getMaxTotal 在接口中 ConnPoolControl<T>

setDefaultMaxPerRoute

public void setDefaultMaxPerRoute(int max)

指定者:

setDefaultMaxPerRoute 在接口中 ConnPoolControl<T>

getDefaultMaxPerRoute

public int getDefaultMaxPerRoute()

指定者:

getDefaultMaxPerRoute 在接口中 ConnPoolControl<T>

setMaxPerRoute

public void setMaxPerRoute(T route,
                  int max)

指定者:

setMaxPerRoute 在接口中 ConnPoolControl<T>

getMaxPerRoute

public int getMaxPerRoute(T route)

指定者:

getMaxPerRoute 在接口中 ConnPoolControl<T>

getTotalStats

public PoolStats getTotalStats()

指定者:

getTotalStats 在接口中 ConnPoolControl<T>

getStats

public PoolStats getStats(T route)

指定者:

getStats 在接口中 ConnPoolControl<T>

enumAvailable

protected void enumAvailable(PoolEntryCallback<T,C> callback)

Enumerates all available connections.

从以下版本开始:

4.3

enumLeased

protected void enumLeased(PoolEntryCallback<T,C> callback)

Enumerates all leased connections.

从以下版本开始:

4.3

enumEntries

@Deprecated
protected void enumEntries(java.util.Iterator<E> it,
                          PoolEntryCallback<T,C> callback)

已过时。 (4.3.2)

Use enumLeased(depends.org.apache.http.pool.PoolEntryCallback) or enumAvailable(depends.org.apache.http.pool.PoolEntryCallback) instead.

closeIdle

public void closeIdle(long idletime,
             java.util.concurrent.TimeUnit tunit)

closeExpired

public void closeExpired()

toString

public java.lang.String toString()

覆盖:

toString 在类中 java.lang.Object