对多渠道的请求中,有时候需要控制请求的响应时间,
在java JDK1.5后,提供的并发包java.util.concurrent为此提供了响应的解决办法。
jdk1.5自带的并发库中Future类就能满足这个需求。
Future类中重要方法包括get()和cancel()。
get()获取数据对象,如果数据没有加载,就会阻塞直到取到数据,而 cancel()是取消数据加载。
另外一个get(timeout)操作,表示如果在timeout时间内没有取到就失败返回,而不再阻塞。
private static final ExecutorService exec = Executors.newCachedThreadPool();
Callable<CloseableHttpResponse> call = new Callable<CloseableHttpResponse>() {
public CloseableHttpResponse call() throws Exception {
return doProcess(configuration.getMethodName());
}
};
Future<CloseableHttpResponse> future = exec.submit(call);
try {
resp = future.get(limitTime, TimeUnit.SECONDS);// 设置请求时间为60秒
} catch (InterruptedException e) {
e.printStackTrace();
//TODO
} catch (ExecutionException e) {
e.printStackTrace();
//TODO
} catch (TimeoutException e) {
e.printStackTrace();
//TODO
}