Package org.apache.http.pool

Class RouteSpecificPool<T,C,E extends PoolEntry<T,C>>

java.lang.Object

org.apache.http.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.LinkedList<java.util.concurrent.Future<E>>	pending
private T	route

Constructor Summary

Constructors

Constructor	Description
RouteSpecificPool(T route)

Method Summary

Modifier and Type	Method	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)

Methods inherited from class java.lang.Object

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

Field Detail

route

private final T route

leased

private final java.util.Set<E extends PoolEntry<T,C>> leased

available

private final java.util.LinkedList<E extends PoolEntry<T,C>> available

pending

private final java.util.LinkedList<java.util.concurrent.Future<E extends PoolEntry<T,C>>> pending

Constructor Detail

RouteSpecificPool

RouteSpecificPool(T route)

Method Detail

createEntry

protected abstract E createEntry(C conn)

getRoute

public final 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)

add

public E add(C conn)

queue

public void queue(java.util.concurrent.Future<E> future)

nextPending

public java.util.concurrent.Future<E> nextPending()

unqueue

public void unqueue(java.util.concurrent.Future<E> future)

shutdown

public void shutdown()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object