摘要：內部類，用于對和異常進行包裝，從而保證對進行只有一次成功。是取消異常，轉換后拋出。判斷是否使用的線程池，在中持有該線程池的引用。

近期作者對響應式編程越發感興趣，在內部分享"JAVA9-12"新特性過程中，有兩處特性讓作者深感興趣：
1.JAVA9中的JEP266對并發編程工具的更新，包含發布訂閱框架Flow和CompletableFuture加強，其中發布訂閱框架以java.base模塊下的java.util.concurrent.Flow及其中的幾個內部類/接口為組成部分，它們的名稱和作用如下，摘自JAVA12的Flow api文檔。

2.JAVA9中孵化，JAVA11中標準化的HttpClient，在之前分享的JAVA9-12新特性一文中曾引用摘自網絡的HttpClient代碼片段：
片段1：

HttpClient client = HttpClient.newHttpClient();
HttpRequest request = HttpRequest.newBuilder()
    .uri(URI.create(uri))
    .build();

return client.sendAsync(request, HttpResponse.BodyHandlers.ofString())
    .thenApply(HttpResponse::body);
}

片段2：

HttpClient client = HttpClient.newHttpClient();
List urls = List.of("http://www.baidu.com","http://www.alibaba.com/","http://www.tencent.com");
List requests = urls.stream()
    .map(url -> HttpRequest.newBuilder(URI.create(url)))
    .map(reqBuilder -> reqBuilder.build())
    .collect(Collectors.toList());

List>> futures = requests.stream()
    .map(request -> client.sendAsync(request, HttpResponse.BodyHandlers.ofString()))
    .collect(Collectors.toList());
futures.stream()
    .forEach(e -> e.whenComplete((resp,err) -> {
        if(err != null){
            err.printStackTrace();
        }else{
            System.out.println(resp.body());
            System.out.println(resp.statusCode());
        }
    }));
CompletableFuture.allOf(futures
    .toArray(CompletableFuture[]::new))
    .join();
}

在片段1中，thenApply方法是CompletableFuture的成員，client.sendAsync返回的是一個CompletableFuture。這兩段代碼很好閱讀，甚至說猜出其中的意義。片段2可以說對于作者目前的書寫習慣是一個全面的顛覆，顯然我們可以預先定義響應行為，而行為的執行時間則由前一個階段的實際完成時間決定。片段2中的whenComplete方法很好理解，最后一行用allOf生成一個類似樹的依賴結構，在當前方法中等待所有CompletableFuture執行完成。

簡單看這兩段代碼，響應式編程的魅力可見一斑，甚至可以說是美妙不可言。
那么，作為JAVA9中額外照顧增強，HttpClient賴以實現的CompletableFuture，它是何方神圣呢？

CompletionStage是什么？不妨賣個關子先。
作者目前使用的JDK版本為8，盡管它不包含9之后的增強，萬幸CompletionStage是從JDK8引入，因此足以用以了解這一偉大神器了。近期作者在公司使用的一些開源框架中，發現至處間接對它的使用：
1.持久化框架Redission。它內部使用一個RedissonExecutorService(實現ScheduledExecutorService）和PromiseDelegator（實現CompletionStage，而CompletableFuture同樣也實現了CompletionStage）來異步地執行task。
2.apollo配置中心。它提供了配置變更的異步通知機制，而這依賴于spring web-mvc提供的DeferredResult，而在異步處理return value時，DeferredResult的setResult同樣也是相應的CompletionStage執行。

//例：阿波羅NotificationControllerV2拉取通知接口
@GetMapping
public DeferredResult>>     pollNotification(
  @RequestParam(value = "appId") String appId,
  @RequestParam(value = "cluster") String cluster,
  @RequestParam(value = "notifications") String notificationsAsString,
  @RequestParam(value = "dataCenter", required = false) String dataCenter,
  @RequestParam(value = "ip", required = false) String clientIp) {
List notifications = null;
//省略無關代碼
//DeferredResultWrapper是apollo作者包裝的spring DeferredResult
DeferredResultWrapper deferredResultWrapper = new DeferredResultWrapper();
//省略無關代碼
if (!CollectionUtils.isEmpty(newNotifications)) {
  deferredResultWrapper.setResult(newNotifications);
} else {
  deferredResultWrapper
      .onTimeout(() -> logWatchedKeys(watchedKeys, "Apollo.LongPoll.TimeOutKeys"));
 
  deferredResultWrapper.onCompletion(() -> {
    //unregister all keys
    for (String key : watchedKeys) {
      deferredResults.remove(key, deferredResultWrapper);
    }
    logWatchedKeys(watchedKeys, "Apollo.LongPoll.CompletedKeys");
  });
 
  //省略
return deferredResultWrapper.getResult();
}

在spring的CompletionStageReturnValueHandler的handleReturnValue（）方法中，如下異步地處理響應結果：

@Override
public void handleReturnValue(Object returnValue, MethodParameter returnType,
        ModelAndViewContainer mavContainer, NativeWebRequest webRequest) throws Exception {
 
    if (returnValue == null) {
        mavContainer.setRequestHandled(true);
        return;
    }
 
    final DeferredResult