Package org.apache.hc.core5.reactor

Class AbstractIOSessionPool<T>

java.lang.Object

org.apache.hc.core5.reactor.AbstractIOSessionPool<T>

All Implemented Interfaces:

Closeable, AutoCloseable, ModalCloseable

Direct Known Subclasses:

H2ConnPool

@Contract(threading=SAFE)
public abstract class AbstractIOSessionPool<T>
extends Object
implements ModalCloseable

Since:

5.0

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	AbstractIOSessionPool.PoolEntry

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicBoolean	closed
private final ConcurrentMap<T,AbstractIOSessionPool.PoolEntry>	sessionPool

Constructor Summary

Constructors

Constructor	Description
AbstractIOSessionPool()

Method Summary

Modifier and Type	Method	Description
final void	close()
final void	close(CloseMode closeMode)	Closes this process or endpoint and releases any system resources associated with it.
final void	closeIdle(TimeValue idleTime)
protected abstract void	closeSession(IOSession ioSession, CloseMode closeMode)
protected abstract Future<IOSession>	connectSession(T namedEndpoint, Timeout connectTimeout, FutureCallback<IOSession> callback)
final void	enumAvailable(Callback<IOSession> callback)
(package private) AbstractIOSessionPool.PoolEntry	getPoolEntry(T endpoint)
final Set<T>	getRoutes()
final Future<IOSession>	getSession(T endpoint, Timeout connectTimeout, FutureCallback<IOSession> callback)
private void	getSessionInternal(AbstractIOSessionPool.PoolEntry poolEntry, boolean requestNew, T namedEndpoint, Timeout connectTimeout, FutureCallback<IOSession> callback)
String	toString()
protected abstract void	validateSession(IOSession ioSession, Callback<Boolean> callback)

Methods inherited from class java.lang.Object

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

Field Details

sessionPool

private final ConcurrentMap<T,AbstractIOSessionPool.PoolEntry> sessionPool

closed

private final AtomicBoolean closed

Constructor Details

AbstractIOSessionPool

public AbstractIOSessionPool()

Method Details

connectSession

protected abstract Future<IOSession> connectSession(T namedEndpoint,
 Timeout connectTimeout,
 FutureCallback<IOSession> callback)

validateSession

protected abstract void validateSession(IOSession ioSession,
 Callback<Boolean> callback)

closeSession

protected abstract void closeSession(IOSession ioSession,
 CloseMode closeMode)

close

public final void close(CloseMode closeMode)

Description copied from interface: ModalCloseable

Closes this process or endpoint and releases any system resources associated with it. If the endpoint or the process is already closed then invoking this method has no effect.

Specified by:

close in interface ModalCloseable

Parameters:

closeMode - How to close the receiver.

close

public final void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

getPoolEntry

AbstractIOSessionPool.PoolEntry getPoolEntry(T endpoint)

getSession

public final Future<IOSession> getSession(T endpoint,
 Timeout connectTimeout,
 FutureCallback<IOSession> callback)

getSessionInternal

private void getSessionInternal(AbstractIOSessionPool.PoolEntry poolEntry,
 boolean requestNew,
 T namedEndpoint,
 Timeout connectTimeout,
 FutureCallback<IOSession> callback)

enumAvailable

public final void enumAvailable(Callback<IOSession> callback)

closeIdle

public final void closeIdle(TimeValue idleTime)

getRoutes

public final Set<T> getRoutes()

toString

public String toString()

Overrides:

toString in class Object