java callable用法_在Java中使用Callable和Future
最近,我們正在開發一個監控儀表板,我們想要ping幾個第三方服務器,只是為了檢查它們的可用性,或者我們想要調用健康檢查。
我們正在對服務器進行一系列api調用,這些服務器的IP,用戶名和密碼被外部化為環境變量。
然后是我們的負載均衡器拋出HTTP 504(網關超時)的挑戰,因為這些請求花了很多時間來返回結果。
因此,我們繼續使用Callable和Future同時進行這些調用以減少所需的時間。
在開發多線程應用程序的傳統方式中,我們創建線程并為其提供Runnable任務。Callable與Runnable非常相似,它有一個細微的區別,它可以返回結果或拋出異常,而Runnable的run方法的返回類型為void。
Runnable runnable = new Runnable() {
@Override
public void run() {
// this can neither return the result nor throw an exception}
}
但是,Callable可以返回任務的結果并且可以拋出異常。您也可以指定結果類型。為簡單起見,我把它作為String,但只要call()方法返回它,它就可以是任何復雜的對象。
Callable callable = new Callable() {
@Override
public String call() throws Exception {
return "this can return output OR can throw Exception";
}
};
既然您有Callable或任務,您需要能夠運行該任務以獲得輸出。您可以使用ExecutorService使用它的submit()方法運行任務,或使用invokeAll()運行多個任務?,您可以在其中提交可調用任務的集合。
現在是有趣的部分,submit()的返回類型是Future ,其中T是輸出(String,如上例所示),invokeAll()的返回類型是List >
Future表示異步計算的結果。Java提供了檢查計算是否完成,等待它完成或從中檢索結果的方法。(它非常類似于javascript承諾,如果這使它易于理解)。因此,為了獲得未來的結果,我們只需要調用get()就可以了
ExecutorService executorService = Executors.newFixedThreadPool(10);
// callable from above codeFuture future = executorService.submit(callable);
String output = future.get();
下面是完整代碼:
public class HealthCheckService {
private HttpHandler httpHandler;
private Config config;
private ExecutorService executor;
public HealthCheckService(HttpHandler httpHandler,Config config) {
this.httpHandler = httpHandler;
this.configuration = configuration;
int size = config.servers.size();
this.executor = Executors.newFixedThreadPool(size);
}
public List getHealthCheck() throws Exception {
List> tasks = prepareTasks(config.uri);
List> futures = executor.invokeAll(tasks);
List output = new ArrayList<>();
for (Future future: futures) {
output.add(future.get());
}
return output;
}
private List> prepareTasks(String api) {
List> tasks = new ArrayList();
for (String server: config.servers) {
tasks.add(() -> httpHandler.getStatus(api));
}
return tasks;
}
}
總結
以上是生活随笔為你收集整理的java callable用法_在Java中使用Callable和Future的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: java中的方法在哪里_Java中的本机
- 下一篇: java 中map_Java中Map集合