Package org.apache.hc.core5.pool
Class LaxConnPool<T,C extends ModalCloseable>
- java.lang.Object
-
- org.apache.hc.core5.pool.LaxConnPool<T,C>
-
- Type Parameters:
T
- routeC
- connection object
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
,ModalCloseable
,ConnPool<T,C>
,ConnPoolControl<T>
,ConnPoolStats<T>
,ManagedConnPool<T,C>
@Contract(threading=SAFE) @Experimental public class LaxConnPool<T,C extends ModalCloseable> extends java.lang.Object implements ManagedConnPool<T,C>
Connection pool with higher concurrency but with lax connection limit guarantees.- Since:
- 5.0
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static class
LaxConnPool.LeaseRequest<T,C extends ModalCloseable>
(package private) static class
LaxConnPool.PerRoutePool<T,C extends ModalCloseable>
-
Field Summary
Fields Modifier and Type Field Description private ConnPoolListener<T>
connPoolListener
private int
defaultMaxPerRoute
private DisposalCallback<C>
disposalCallback
private java.util.concurrent.atomic.AtomicBoolean
isShutDown
private PoolReusePolicy
policy
private java.util.concurrent.ConcurrentMap<T,LaxConnPool.PerRoutePool<T,C>>
routeToPool
private TimeValue
timeToLive
-
Constructor Summary
Constructors Constructor Description LaxConnPool(int defaultMaxPerRoute)
LaxConnPool(int defaultMaxPerRoute, TimeValue timeToLive, PoolReusePolicy policy, ConnPoolListener<T> connPoolListener)
LaxConnPool(int defaultMaxPerRoute, TimeValue timeToLive, PoolReusePolicy policy, DisposalCallback<C> disposalCallback, ConnPoolListener<T> connPoolListener)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
void
close(CloseMode closeMode)
Closes this process or endpoint and releases any system resources associated with it.void
closeExpired()
void
closeIdle(TimeValue idleTime)
void
enumAvailable(Callback<PoolEntry<T,C>> callback)
void
enumLeased(Callback<PoolEntry<T,C>> callback)
int
getDefaultMaxPerRoute()
int
getMaxPerRoute(T route)
int
getMaxTotal()
private LaxConnPool.PerRoutePool<T,C>
getPool(T route)
java.util.Set<T>
getRoutes()
PoolStats
getStats(T route)
PoolStats
getTotalStats()
boolean
isShutdown()
java.util.concurrent.Future<PoolEntry<T,C>>
lease(T route, java.lang.Object state)
java.util.concurrent.Future<PoolEntry<T,C>>
lease(T route, java.lang.Object state, Timeout requestTimeout, FutureCallback<PoolEntry<T,C>> callback)
Attempts to lease a connection for the given route and with the given state from the pool.void
release(PoolEntry<T,C> entry, boolean reusable)
Releases the pool entry back to the pool.void
setDefaultMaxPerRoute(int max)
void
setMaxPerRoute(T route, int max)
void
setMaxTotal(int max)
java.lang.String
toString()
void
validatePendingRequests()
-
-
-
Field Detail
-
timeToLive
private final TimeValue timeToLive
-
policy
private final PoolReusePolicy policy
-
disposalCallback
private final DisposalCallback<C extends ModalCloseable> disposalCallback
-
connPoolListener
private final ConnPoolListener<T> connPoolListener
-
routeToPool
private final java.util.concurrent.ConcurrentMap<T,LaxConnPool.PerRoutePool<T,C extends ModalCloseable>> routeToPool
-
isShutDown
private final java.util.concurrent.atomic.AtomicBoolean isShutDown
-
defaultMaxPerRoute
private volatile int defaultMaxPerRoute
-
-
Constructor Detail
-
LaxConnPool
public LaxConnPool(int defaultMaxPerRoute, TimeValue timeToLive, PoolReusePolicy policy, DisposalCallback<C> disposalCallback, ConnPoolListener<T> connPoolListener)
- Since:
- 5.0
-
LaxConnPool
public LaxConnPool(int defaultMaxPerRoute, TimeValue timeToLive, PoolReusePolicy policy, ConnPoolListener<T> connPoolListener)
- Since:
- 5.0
-
LaxConnPool
public LaxConnPool(int defaultMaxPerRoute)
-
-
Method Detail
-
isShutdown
public boolean isShutdown()
-
close
public void close(CloseMode closeMode)
Description copied from interface:ModalCloseable
Closes this process or endpoint and releases any system resources associated with it. If the endpoint or the process is already closed then invoking this method has no effect.- Specified by:
close
in interfaceModalCloseable
- Parameters:
closeMode
- How to close the receiver.
-
close
public void close()
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
-
getPool
private LaxConnPool.PerRoutePool<T,C> getPool(T route)
-
lease
public java.util.concurrent.Future<PoolEntry<T,C>> lease(T route, java.lang.Object state, Timeout requestTimeout, FutureCallback<PoolEntry<T,C>> callback)
Description copied from interface:ConnPool
Attempts to lease a connection for the given route and with the given state from the pool.Please note the connection request can get automatically cancelled by the pool in case of a request timeout.
- Specified by:
lease
in interfaceConnPool<T,C extends ModalCloseable>
- Parameters:
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 benull
.requestTimeout
- request timeout. In case of a timeout the request can get automatically cancelled by the pool.callback
- operation completion callback.- Returns:
- future for a leased pool entry.
-
release
public void release(PoolEntry<T,C> entry, boolean reusable)
Description copied from interface:ConnPool
Releases the pool entry back to the pool.- Specified by:
release
in interfaceConnPool<T,C extends ModalCloseable>
- Parameters:
entry
- pool entry leased from the poolreusable
- flag indicating whether or not the released connection is in a consistent state and is safe for further use.
-
validatePendingRequests
public void validatePendingRequests()
-
setMaxTotal
public void setMaxTotal(int max)
- Specified by:
setMaxTotal
in interfaceConnPoolControl<T>
-
getMaxTotal
public int getMaxTotal()
- Specified by:
getMaxTotal
in interfaceConnPoolControl<T>
-
setDefaultMaxPerRoute
public void setDefaultMaxPerRoute(int max)
- Specified by:
setDefaultMaxPerRoute
in interfaceConnPoolControl<T>
-
getDefaultMaxPerRoute
public int getDefaultMaxPerRoute()
- Specified by:
getDefaultMaxPerRoute
in interfaceConnPoolControl<T>
-
setMaxPerRoute
public void setMaxPerRoute(T route, int max)
- Specified by:
setMaxPerRoute
in interfaceConnPoolControl<T>
-
getMaxPerRoute
public int getMaxPerRoute(T route)
- Specified by:
getMaxPerRoute
in interfaceConnPoolControl<T>
-
getTotalStats
public PoolStats getTotalStats()
- Specified by:
getTotalStats
in interfaceConnPoolStats<T>
-
getStats
public PoolStats getStats(T route)
- Specified by:
getStats
in interfaceConnPoolStats<T>
-
getRoutes
public java.util.Set<T> getRoutes()
- Specified by:
getRoutes
in interfaceConnPoolControl<T>
-
closeIdle
public void closeIdle(TimeValue idleTime)
- Specified by:
closeIdle
in interfaceConnPoolControl<T>
-
closeExpired
public void closeExpired()
- Specified by:
closeExpired
in interfaceConnPoolControl<T>
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-