ForkJoinPool在CompletableFuture.SupplyAsync（）中的行为

Question

我比较了CompletableFuture.SupplyAsync（）在以下两种情况下的行为：我设置了一个自定义ExecutorService，或者我希望我的供应商由默认的executor（如果没有指定）执行，这两种情况是forkJoinPool.commonpool（）

public class MainApplication {
  public static void main(final String[] args) throws ExecutionException, InterruptedException {

    Supplier<String> action1 = () -> {
        try {
            Thread.sleep(3000);
        }finally {
            return "Done";
        }
    };
    Function<String, String> action2 = (input) -> {
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }finally {
            return input + "!!";
        }
    };

    final ExecutorService executorService = Executors.newFixedThreadPool(4);

    CompletableFuture.supplyAsync(action1, executorService)
                     .thenApply  (action2)
                     .thenAccept (res -> System.out.println(res));

    System.out.println("This is the end of the execution");

  }
}

完成了！！

所以“done”会在主执行结束后打印出来。

但如果我用：

CompletableFuture.supplyAsync(action1)

Answer 1

在这两种情况下

CompletableFuture.supplyAsync(action1, executorService)
                     .thenApply  (action2)
                     .thenAccept (res -> System.out.println(res));

你不会等待任务完成。但是接下来你的程序要退出了，而常见的fork加入池有何不同：

ForkJoinPool.commonPool()

和定期执行人服务：

final ExecutorService executorService = Executors.newFixedThreadPool(4);

shutdown（）方法将允许以前提交的任务在终止之前执行

我想这可能是你问的不同之处。