Package org.apache.http.nio.pool
Class RouteSpecificPool<T,C,E extends PoolEntry<T,C>>
- java.lang.Object
-
- org.apache.http.nio.pool.RouteSpecificPool<T,C,E>
-
abstract class RouteSpecificPool<T,C,E extends PoolEntry<T,C>> extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description private java.util.LinkedList<E>
available
private java.util.Set<E>
leased
private java.util.Map<SessionRequest,BasicFuture<E>>
pending
private T
route
-
Constructor Summary
Constructors Constructor Description RouteSpecificPool(T route)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method 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, java.lang.Exception ex)
void
free(E entry, boolean reusable)
int
getAllocatedCount()
int
getAvailableCount()
E
getFree(java.lang.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)
java.lang.String
toString()
-
-
-
Constructor Detail
-
RouteSpecificPool
RouteSpecificPool(T route)
-
-
Method Detail
-
getRoute
public T getRoute()
-
getLeasedCount
public int getLeasedCount()
-
getPendingCount
public int getPendingCount()
-
getAvailableCount
public int getAvailableCount()
-
getAllocatedCount
public int getAllocatedCount()
-
getFree
public E getFree(java.lang.Object state)
-
getLastUsed
public E getLastUsed()
-
remove
public boolean remove(E entry)
-
free
public void free(E entry, boolean reusable)
-
addPending
public void addPending(SessionRequest request, BasicFuture<E> future)
-
removeRequest
private BasicFuture<E> removeRequest(SessionRequest request)
-
createEntry
public E createEntry(SessionRequest request, C conn)
-
completed
public boolean completed(SessionRequest request, E entry)
-
cancelled
public void cancelled(SessionRequest request)
-
failed
public void failed(SessionRequest request, java.lang.Exception ex)
-
timeout
public void timeout(SessionRequest request)
-
shutdown
public void shutdown()
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-