java - 来自 ExecutorService 的 CompletableFuture

Question

我已经创建了一个自定义的 ExecutorService

ExecutorService executor =
        new ThreadPoolExecutor(0, maxPoolSize, keepAliveTime, timeUnit,
                               new LinkedBlockingDeque<>());

我向其提交我的任务

Future<String> result = executor.submit(() -> "test");

如您所见，执行器返回了一个微不足道的Future；我宁愿有一个 CompletableFuture我可以与其他 CompletableFuture 链接。

在Guava , 我们有 ListeningExecutorService返回 ListenableFutures .就我的意图和目的而言，那些 ListenableFuture 与 CompletableFuture 一样好。

不过，我还是想尽可能多地使用 Java 的标准库，这意味着我正在寻找一种方法来从我的自定义执行程序中获取 CompletableFuture。

Answer 1

事后看来很明显:不要尝试从执行器获取 CompletableFuture，而是将执行器传递给 CompletableFuture。

像这样:

CompletableFuture<String> futureOutput =
        CompletableFuture.supplyAsync(() -> "test", executor);

任务将使用 executor 提供的线程之一执行，客户端可以使用 CompletableFuture 的所有便利来获取任务结果。