我正在编写一个库，该库提供了几个返回“可完成未来”的异步方法。该库具有一个内部线程池，用于执行异步方法的计算工作。
我想确保满足以下两个要求：
所以说图书馆有以下阻止方法
Data request(Address address) {
Message request = encode(address);
Message response = sendAndReceive(request);
Data responseData = decode(response);
return responseData;
}
和相应的异步方法
CompletableFuture<Data> requestAsync(Address address) {
return CompletableFuture.supplyAsync(() -> encode(address), internalThreadPool)
.thenCompose(request -> sendAndReceiveAsync(request))
.thenApply(response -> decode(response));
}
第一个要求是通过添加链接来满足的。当完成同步（（v，t） -
但是，为了满足第二个要求，需要做些什么呢？
Sergey Kuksenko在这里讨论了第二个需求的解决方案，并已在Java11的HttpClient实现中实现。
不满足要求，因为不能保证decode（响应）由内部线程执行。如果encode和sendAndReceiveAsync快速完成，decode实际上可以由调用者的线程执行。
可以通过引入CompletableFuturestartCf来启动CF链来解决该问题。
因此，完整的解决方案可能如下所示
CompletableFuture<Data> requestAsyncFixedAll(Address address) {
CompletableFuture<Void> startCf = new CompletableFuture<>();
CompletableFuture<Data> dataCf = startCf.thenApplyAsync(v -> encode(address), internalThreadPool)
.thenCompose(request -> sendAndReceiveAsync(request))
.thenApply(response -> decode(response)).whenCompleteAsync((v, t) -> {});
startCf.complete(null);
return dataCf;
}
