Package org.apache.http.impl.client

Class FutureRequestExecutionService

java.lang.Object

org.apache.http.impl.client.FutureRequestExecutionService

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

@Contract(threading=SAFE)
public class FutureRequestExecutionService
extends java.lang.Object
implements java.io.Closeable

HttpAsyncClientWithFuture wraps calls to execute with a HttpRequestFutureTask and schedules them using the provided executor service. Scheduled calls may be cancelled.

Constructor Summary

Constructors

Constructor	Description
FutureRequestExecutionService(HttpClient httpclient, java.util.concurrent.ExecutorService executorService)	Create a new FutureRequestExecutionService.

Method Summary

Modifier and Type	Method	Description
void	close()
<T> HttpRequestFutureTask<T>	execute(HttpUriRequest request, org.apache.http.protocol.HttpContext context, ResponseHandler<T> responseHandler)	Schedule a request for execution.
<T> HttpRequestFutureTask<T>	execute(HttpUriRequest request, org.apache.http.protocol.HttpContext context, ResponseHandler<T> responseHandler, org.apache.http.concurrent.FutureCallback<T> callback)	Schedule a request for execution.
FutureRequestExecutionMetrics	metrics()

Methods inherited from class java.lang.Object

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

Constructor Detail

FutureRequestExecutionService

public FutureRequestExecutionService(HttpClient httpclient,
                                     java.util.concurrent.ExecutorService executorService)

Create a new FutureRequestExecutionService.

Parameters:

httpclient - you should tune your httpclient instance to match your needs. You should align the max number of connections in the pool and the number of threads in the executor; it doesn't make sense to have more threads than connections and if you have less connections than threads, the threads will just end up blocking on getting a connection from the pool.

executorService - any executorService will do here. E.g. Executors.newFixedThreadPool(int)

Method Detail

execute

public <T> HttpRequestFutureTask<T> execute(HttpUriRequest request,
                                            org.apache.http.protocol.HttpContext context,
                                            ResponseHandler<T> responseHandler)

Schedule a request for execution.

Type Parameters:

T -

Parameters:

request - request to execute

responseHandler - handler that will process the response.

Returns:

HttpAsyncClientFutureTask for the scheduled request.

execute

public <T> HttpRequestFutureTask<T> execute(HttpUriRequest request,
                                            org.apache.http.protocol.HttpContext context,
                                            ResponseHandler<T> responseHandler,
                                            org.apache.http.concurrent.FutureCallback<T> callback)

Schedule a request for execution.

Type Parameters:

T -

Parameters:

request - request to execute

context - optional context; use null if not needed.

responseHandler - handler that will process the response.

callback - callback handler that will be called when the request is scheduled, started, completed, failed, or cancelled.

Returns:

HttpAsyncClientFutureTask for the scheduled request.

metrics

public FutureRequestExecutionMetrics metrics()

Returns:

metrics gathered for this instance.

See Also:

FutureRequestExecutionMetrics

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Throws:

java.io.IOException