abstract class RouteSpecificPool<T,C,E extends PoolEntry<T,C>>
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private java.util.LinkedList<E> |
available |
private java.util.Set<E> |
leased |
private java.util.LinkedList<java.util.concurrent.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(java.lang.Object state) |
E |
getLastUsed() |
int |
getLeasedCount() |
int |
getPendingCount() |
T |
getRoute() |
java.util.concurrent.Future<E> |
nextPending() |
void |
queue(java.util.concurrent.Future<E> future) |
boolean |
remove(E entry) |
void |
shutdown() |
java.lang.String |
toString() |
void |
unqueue(java.util.concurrent.Future<E> future) |
private final T route
RouteSpecificPool(T route)
public final T getRoute()
public int getLeasedCount()
public int getPendingCount()
public int getAvailableCount()
public int getAllocatedCount()
public E getFree(java.lang.Object state)
public E getLastUsed()
public boolean remove(E entry)
public void free(E entry, boolean reusable)
public void queue(java.util.concurrent.Future<E> future)
public java.util.concurrent.Future<E> nextPending()
public void unqueue(java.util.concurrent.Future<E> future)
public void shutdown()
public java.lang.String toString()
toString
in class java.lang.Object