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 LinkedList<Future<E>> |
pending |
private T |
route |
Constructor and Description |
---|
RouteSpecificPool(T route) |
Modifier and Type | Method and Description |
---|---|
E |
add(C conn) |
protected abstract E |
createEntry(C conn) |
void |
free(E entry,
boolean reusable) |
int |
getAllocatedCount() |
int |
getAvailableCount() |
E |
getFree(Object state) |
E |
getLastUsed() |
int |
getLeasedCount() |
int |
getPendingCount() |
T |
getRoute() |
Future<E> |
nextPending() |
void |
queue(Future<E> future) |
boolean |
remove(E entry) |
void |
shutdown() |
String |
toString() |
void |
unqueue(Future<E> future) |
RouteSpecificPool(T route)
protected abstract E createEntry(C conn)
public int getLeasedCount()
public int getPendingCount()
public int getAvailableCount()
public int getAllocatedCount()
public E getLastUsed()
public Future<E> nextPending()
public void shutdown()
WebARTS Library Licensed Under the GNU - General Public License. Other Libraries licensed under their respective Open Source Licenses