org.apache.hc.client5.http.impl.nio

Class H2SharingConnPool<T,C extends org.apache.hc.core5.http.HttpConnection>

java.lang.Object

org.apache.hc.client5.http.impl.nio.H2SharingConnPool<T,C>

Type Parameters:

T - route

C - connection object

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hc.core5.io.ModalCloseable, org.apache.hc.core5.pool.ConnPool<T,C>, org.apache.hc.core5.pool.ConnPoolControl<T>, org.apache.hc.core5.pool.ConnPoolStats<T>, org.apache.hc.core5.pool.ManagedConnPool<T,C>

@Contract(threading=SAFE)
 @Experimental
public class H2SharingConnPool<T,C extends org.apache.hc.core5.http.HttpConnection>
extends Object
implements org.apache.hc.core5.pool.ManagedConnPool<T,C>

Experimental connections pool implementation that acts as a caching facade in front of a standard ManagedConnPool and shares already leased connections to multiplex message exchanges over active HTTP/2 connections.

Since:

5.5

Constructor Summary

Constructors

Constructor and Description
H2SharingConnPool(org.apache.hc.core5.pool.ManagedConnPool<T,C> pool)

Method Summary

Modifier and Type	Method and Description
void	close()
void	close(org.apache.hc.core5.io.CloseMode closeMode)
void	closeExpired()
void	closeIdle(org.apache.hc.core5.util.TimeValue idleTime)
int	getDefaultMaxPerRoute()
int	getMaxPerRoute(T route)
int	getMaxTotal()
Set<T>	getRoutes()
org.apache.hc.core5.pool.PoolStats	getStats(T route)
org.apache.hc.core5.pool.PoolStats	getTotalStats()
Future<org.apache.hc.core5.pool.PoolEntry<T,C>>	lease(T route, Object state, org.apache.hc.core5.util.Timeout requestTimeout, org.apache.hc.core5.concurrent.FutureCallback<org.apache.hc.core5.pool.PoolEntry<T,C>> callback)
void	release(org.apache.hc.core5.pool.PoolEntry<T,C> entry, boolean reusable)
void	setDefaultMaxPerRoute(int max)
void	setMaxPerRoute(T route, int max)
void	setMaxTotal(int max)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

H2SharingConnPool

public H2SharingConnPool(org.apache.hc.core5.pool.ManagedConnPool<T,C> pool)

Method Detail

close

public void close(org.apache.hc.core5.io.CloseMode closeMode)

Specified by:

close in interface org.apache.hc.core5.io.ModalCloseable

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

lease

public Future<org.apache.hc.core5.pool.PoolEntry<T,C>> lease(T route,
                                                             Object state,
                                                             org.apache.hc.core5.util.Timeout requestTimeout,
                                                             org.apache.hc.core5.concurrent.FutureCallback<org.apache.hc.core5.pool.PoolEntry<T,C>> callback)

Specified by:

lease in interface org.apache.hc.core5.pool.ConnPool<T,C extends org.apache.hc.core5.http.HttpConnection>

release

public void release(org.apache.hc.core5.pool.PoolEntry<T,C> entry,
                    boolean reusable)

Specified by:

release in interface org.apache.hc.core5.pool.ConnPool<T,C extends org.apache.hc.core5.http.HttpConnection>

setMaxTotal

public void setMaxTotal(int max)

Specified by:

setMaxTotal in interface org.apache.hc.core5.pool.ConnPoolControl<T>

getMaxTotal

public int getMaxTotal()

Specified by:

getMaxTotal in interface org.apache.hc.core5.pool.ConnPoolControl<T>

setDefaultMaxPerRoute

public void setDefaultMaxPerRoute(int max)

Specified by:

setDefaultMaxPerRoute in interface org.apache.hc.core5.pool.ConnPoolControl<T>

getDefaultMaxPerRoute

public int getDefaultMaxPerRoute()

Specified by:

getDefaultMaxPerRoute in interface org.apache.hc.core5.pool.ConnPoolControl<T>

setMaxPerRoute

public void setMaxPerRoute(T route,
                           int max)

Specified by:

setMaxPerRoute in interface org.apache.hc.core5.pool.ConnPoolControl<T>

getMaxPerRoute

public int getMaxPerRoute(T route)

Specified by:

getMaxPerRoute in interface org.apache.hc.core5.pool.ConnPoolControl<T>

closeIdle

public void closeIdle(org.apache.hc.core5.util.TimeValue idleTime)

Specified by:

closeIdle in interface org.apache.hc.core5.pool.ConnPoolControl<T>

closeExpired

public void closeExpired()

Specified by:

closeExpired in interface org.apache.hc.core5.pool.ConnPoolControl<T>

getRoutes

public Set<T> getRoutes()

Specified by:

getRoutes in interface org.apache.hc.core5.pool.ConnPoolControl<T>

getTotalStats

public org.apache.hc.core5.pool.PoolStats getTotalStats()

Specified by:

getTotalStats in interface org.apache.hc.core5.pool.ConnPoolStats<T>

getStats

public org.apache.hc.core5.pool.PoolStats getStats(T route)

Specified by:

getStats in interface org.apache.hc.core5.pool.ConnPoolStats<T>

toString

public String toString()

Overrides:

toString in class Object