何时Completable Future releases线程将返回到线程池？

Question

当CompletableFuture释放线程回到Threadpool？是调用get（）方法后还是关联任务完成后？

Answer 1

get调用和池中的线程之间没有关系。未来的完成和线程之间甚至没有关系。

一个CompletableFuture可以从任何地方完成，例如通过调用完成。当您使用一种方便的方法将任务调度到最终将尝试完成它的执行器时，线程将一直使用到完成尝试完成时，无论未来是否已经完成。

例如，

CompletableFuture<String> f = CompletableFuture.supplyAsync(() -> "hello");

在语义上等同于

CompletableFuture<String> f = new CompletableFuture<>();

ForkJoinPool.commonPool().execute(() -> {
    try {
        f.complete("hello");
    } catch(Throwable t) {
        f.completeExceptionally(t);
    }
});

很明显，线程池和计划的操作都不关心将来是否有人调用get（）或加入（）。

即使您提前完成未来，例如通过complete（“某些其他字符串”）或通过cancel（…），也不会影响正在进行的计算，因为没有从未来到作业的引用。正如cancel的文档所述：

MayInterruptFrunning-此值在此实现中无效，因为中断不用于控制处理。

鉴于上述解释，原因应该很清楚。

创建依赖链时存在差异，例如通过b=a.then应用（函数）。将评估函数的作业在完成a之前不会提交。到a完成时，将在函数的计算开始之前重新检查b的完成状态。如果此时已完成b，则可能会跳过计算。

CompletableFuture<String> a = CompletableFuture.supplyAsync(() -> {
    LockSupport.parkNanos(TimeUnit.SECONDS.toNanos(1));
    return "foo";
});
CompletableFuture<String> b = a.thenApplyAsync(string -> {
    System.out.println("starting to evaluate "+string);
    LockSupport.parkNanos(TimeUnit.SECONDS.toNanos(2));
    System.out.println("finishing to evaluate "+string);
    return string.toUpperCase();
});
b.complete("faster");
System.out.println(b.join());
ForkJoinPool.commonPool().awaitQuiescence(1, TimeUnit.DAYS);

只需打印

faster

但一旦评估开始就无法停止了所以

CompletableFuture<String> a = CompletableFuture.supplyAsync(() -> {
    LockSupport.parkNanos(TimeUnit.SECONDS.toNanos(1));
    return "foo";
});
CompletableFuture<String> b = a.thenApplyAsync(string -> {
    System.out.println("starting to evaluate "+string);
    LockSupport.parkNanos(TimeUnit.SECONDS.toNanos(2));
    System.out.println("finishing to evaluate "+string);
    return string.toUpperCase();
});
LockSupport.parkNanos(TimeUnit.SECONDS.toNanos(2));
b.complete("faster");
System.out.println(b.join());
ForkJoinPool.commonPool().awaitQuiescence(1, TimeUnit.DAYS);

会打印

starting to evaluate foo
faster
finishing to evaluate foo

这表明，即使在您成功地从较早完成的未来检索到值时，仍可能有一个仍在运行的后台计算将尝试完成未来。但随后的完成尝试将被忽略。