abstract class RouteSpecificPool<T,C,E extends PoolEntry<T,C>> extends Object
Modifier and Type | Field and Description |
---|---|
private LinkedList<E> |
available |
private Set<E> |
leased |
private Map<SessionRequest,BasicFuture<E>> |
pending |
private T |
route |
Constructor and Description |
---|
RouteSpecificPool(T route) |
Modifier and Type | Method and Description |
---|---|
void |
addPending(SessionRequest request,
BasicFuture<E> future) |
void |
cancelled(SessionRequest request) |
boolean |
completed(SessionRequest request,
E entry) |
E |
createEntry(SessionRequest request,
C conn) |
protected abstract E |
createEntry(T route,
C conn) |
void |
failed(SessionRequest request,
Exception ex) |
void |
free(E entry,
boolean reusable) |
int |
getAllocatedCount() |
int |
getAvailableCount() |
E |
getFree(Object state) |
E |
getLastUsed() |
int |
getLeasedCount() |
int |
getPendingCount() |
T |
getRoute() |
boolean |
remove(E entry) |
private BasicFuture<E> |
removeRequest(SessionRequest request) |
void |
shutdown() |
void |
timeout(SessionRequest request) |
String |
toString() |
private final Map<SessionRequest,BasicFuture<E extends PoolEntry<T,C>>> pending
RouteSpecificPool(T route)
protected abstract E createEntry(T route, C conn)
public int getLeasedCount()
public int getPendingCount()
public int getAvailableCount()
public int getAllocatedCount()
public E getLastUsed()
public void addPending(SessionRequest request, BasicFuture<E> future)
private BasicFuture<E> removeRequest(SessionRequest request)
public E createEntry(SessionRequest request, C conn)
public boolean completed(SessionRequest request, E entry)
public void cancelled(SessionRequest request)
public void failed(SessionRequest request, Exception ex)
public void timeout(SessionRequest request)
public void shutdown()
WebARTS Library Licensed Under the GNU - General Public License. Other Libraries licensed under their respective Open Source Licenses