在Java中使用Callable和Future
摘要：
最近，我們正在開發一個監控儀表板，我們想要ping幾個第三方伺服器，只是為了檢查它們的可用性，或者我們想要呼叫健康檢查。
我們正在對伺服器進行一系列api呼叫，這些伺服器的IP，使用者名稱和密碼被外部化為環境變數。
然後是我們的負載均衡器丟擲HTTP 504（閘道器超時）的挑戰，因為這...
最近，我們正在開發一個監控儀表板，我們想要ping幾個第三方伺服器，只是為了檢查它們的可用性，或者我們想要呼叫健康檢查。
我們正在對伺服器進行一系列api呼叫，這些伺服器的IP，使用者名稱和密碼被外部化為環境變數。
然後是我們的負載均衡器丟擲HTTP 504（閘道器超時）的挑戰，因為這些請求花了很多時間來返回結果。
因此，我們繼續使用Callable和Future同時進行這些呼叫以減少所需的時間。
在開發多執行緒應用程式的傳統方式中，我們建立執行緒併為其提供Runnable任務。Callable與Runnable非常相似，它有一個細微的區別，它可以返回結果或丟擲異常，而Runnable的run方法的返回型別為void。
Runnable runnable = <b>new</b> Runnable() {
@Override
<b>public</b> <b>void</b> run() {
<font><i>// this can neither return the result nor throw an exception</i></font><font>
}
}
</font>
但是，Callable可以返回任務的結果並且可以丟擲異常。您也可以指定結果型別。為簡單起見，我把它作為String，但只要call（）方法返回它，它就可以是任何複雜的物件。
Callable<String> callable = <b>new</b> Callable<String>() {
@Override
<b>public</b> String call() throws Exception {
<b>return</b> <font>"this can return output OR can throw Exception"</font><font>;
}
};
</font>
既然您有Callable或任務，您需要能夠執行該任務以獲得輸出。您可以使用ExecutorService使用它的submit（）方法執行任務，或使用invokeAll（）執行多個任務 ，您可以在其中提交可呼叫任務的集合。
現在是有趣的部分，submit（）的返回型別是Future <T>，其中T是輸出（String，如上例所示），invokeAll（）的返回型別是List <Future <T >>
Future表示非同步計算的結果。Java提供了檢查計算是否完成，等待它完成或從中檢索結果的方法。（它非常類似於javascript承諾，如果這使它易於理解）。因此，為了獲得未來的結果，我們只需要呼叫get（）就可以了
ExecutorService executorService = Executors.newFixedThreadPool(10); <font><i>// callable from above code</i></font><font> Future<String> future = executorService.submit(callable); String output = future.get(); </font>
下面是完整程式碼：
<b>public</b> <b>class</b> HealthCheckService {
<b>private</b> HttpHandler httpHandler;
<b>private</b> Config config;
<b>private</b> ExecutorService executor;
<b>public</b> HealthCheckService(HttpHandler httpHandler,Config config) {
<b>this</b>.httpHandler = httpHandler;
<b>this</b>.configuration = configuration;
<b>int</b> size = config.servers.size();
<b>this</b>.executor = Executors.newFixedThreadPool(size);
}
<b>public</b> List<HealthCheckResult> getHealthCheck() throws Exception {
List<Callable<HealthCheck>> tasks = prepareTasks(config.uri);
List<Future<HealthCheck>> futures = executor.invokeAll(tasks);
List<HealthCheck> output = <b>new</b> ArrayList<>();
<b>for</b> (Future<HealthCheckResult> future: futures) {
output.add(future.get());
}
<b>return</b> output;
}
<b>private</b> List<Callable<HealthCheck>> prepareTasks(String api) {
List<Callable<HealthCheckResult>> tasks = <b>new</b> ArrayList();
<b>for</b> (String server: config.servers) {
tasks.add(() -> httpHandler.getStatus(api));
}
<b>return</b> tasks;
}
}