Package org.apache.hc.core5.pool

Class LaxConnPool.PerRoutePool<T,C extends ModalCloseable>

java.lang.Object

org.apache.hc.core5.pool.LaxConnPool.PerRoutePool<T,C>

Enclosing class:

LaxConnPool<T,C extends ModalCloseable>

static class LaxConnPool.PerRoutePool<T,C extends ModalCloseable>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static enum	LaxConnPool.PerRoutePool.RequestServiceStrategy

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicInteger	allocated
private final Deque<AtomicMarkableReference<PoolEntry<T,C>>>	available
private final ConnPoolListener<T>	connPoolListener
private final ConnPoolStats<T>	connPoolStats
private final DisposalCallback<C>	disposalCallback
private final ConcurrentMap<PoolEntry<T,C>,Boolean>	leased
private int	max
private final Deque<LaxConnPool.LeaseRequest<T,C>>	pending
private final PoolReusePolicy	policy
private final AtomicLong	releaseSeqNum
private final T	route
private final AtomicBoolean	terminated
private final TimeValue	timeToLive

Constructor Summary

Constructors

Constructor	Description
PerRoutePool(T route, int max, TimeValue timeToLive, PoolReusePolicy policy, ConnPoolStats<T> connPoolStats, DisposalCallback<C> disposalCallback, ConnPoolListener<T> connPoolListener)

Method Summary

Modifier and Type	Method	Description
private void	addLeased(PoolEntry<T,C> entry)
private PoolEntry<T,C>	createPoolEntry()
private void	deallocatePoolEntry()
void	enumAvailable(Callback<PoolEntry<T,C>> callback)
void	enumLeased(Callback<PoolEntry<T,C>> callback)
int	getAvailableCount()
private PoolEntry<T,C>	getAvailableEntry(Object state)
int	getLeasedCount()
int	getMax()
int	getPendingCount()
final T	getRoute()
Future<PoolEntry<T,C>>	lease(Object state, Timeout requestTimeout, FutureCallback<PoolEntry<T,C>> callback)
void	release(PoolEntry<T,C> releasedEntry, boolean reusable)
private void	removeLeased(PoolEntry<T,C> entry)
private void	servicePendingRequest()
private void	servicePendingRequests(LaxConnPool.PerRoutePool.RequestServiceStrategy serviceStrategy)
void	setMax(int max)
void	shutdown(CloseMode closeMode)
String	toString()
void	validatePendingRequests()

Methods inherited from class java.lang.Object

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

Field Details

route

private final T route

timeToLive

private final TimeValue timeToLive

policy

private final PoolReusePolicy policy

disposalCallback

private final DisposalCallback<C extends ModalCloseable> disposalCallback

connPoolListener

private final ConnPoolListener<T> connPoolListener

connPoolStats

private final ConnPoolStats<T> connPoolStats

leased

private final ConcurrentMap<PoolEntry<T,C extends ModalCloseable>,Boolean> leased

available

private final Deque<AtomicMarkableReference<PoolEntry<T,C extends ModalCloseable>>> available

pending

private final Deque<LaxConnPool.LeaseRequest<T,C extends ModalCloseable>> pending

terminated

private final AtomicBoolean terminated

allocated

private final AtomicInteger allocated

releaseSeqNum

private final AtomicLong releaseSeqNum

max

private volatile int max

Constructor Details

PerRoutePool

PerRoutePool(T route,
 int max,
 TimeValue timeToLive,
 PoolReusePolicy policy,
 ConnPoolStats<T> connPoolStats,
 DisposalCallback<C> disposalCallback,
 ConnPoolListener<T> connPoolListener)

Method Details

shutdown

public void shutdown(CloseMode closeMode)

createPoolEntry

private PoolEntry<T,C> createPoolEntry()

deallocatePoolEntry

private void deallocatePoolEntry()

addLeased

private void addLeased(PoolEntry<T,C> entry)

removeLeased

private void removeLeased(PoolEntry<T,C> entry)

getAvailableEntry

private PoolEntry<T,C> getAvailableEntry(Object state)

lease

public Future<PoolEntry<T,C>> lease(Object state,
 Timeout requestTimeout,
 FutureCallback<PoolEntry<T,C>> callback)

release

public void release(PoolEntry<T,C> releasedEntry,
 boolean reusable)

servicePendingRequest

private void servicePendingRequest()

servicePendingRequests

private void servicePendingRequests(LaxConnPool.PerRoutePool.RequestServiceStrategy serviceStrategy)

validatePendingRequests

public void validatePendingRequests()

getRoute

public final T getRoute()

getMax

public int getMax()

setMax

public void setMax(int max)

getPendingCount

public int getPendingCount()

getLeasedCount

public int getLeasedCount()

getAvailableCount

public int getAvailableCount()

enumAvailable

public void enumAvailable(Callback<PoolEntry<T,C>> callback)

enumLeased

public void enumLeased(Callback<PoolEntry<T,C>> callback)

toString

public String toString()

Overrides:

toString in class Object