线程与CompletableFuture

Question

将代码直接传递给线程vs使用CompletableFuture的优势是什么？

Thread thread = new Thread(() -> {do something});
thread.start();

VS

CompletableFuture<Void> cf1 =  
     CompletableFuture.runAsync(() -> {do something}); 

Answer 1

CompletableFuture.runAsync(...)在托管的forkJoin-Pool中运行Runnable ,同时new Thread()创建一个你必须管理的新线程.

什么是"被管理"的意思,它的预分配和线程在JVM共享.当runnable完成后,该线程可以重用于其他runnables.这样可以更好地利用资源,特别是当线程实例化是一项昂贵的操作时 - 不仅要对象,而且还要分配一些额外的非堆内存 - 线程堆栈.

Answer 2

@Gerald Mücke 已经提到了重要的区别：

CompletableFuture.runAsync(...) 在托管的 forkJoin-Pool 中运行 Runnable，而 new Thread() 创建一个您必须管理的新线程。

CompletableFuture 将使用由ThreadPool（默认或自定义）管理的线程。

但是，我认为以下两点也是应该考虑的。

第一的

CompletableFuture有这么多的容易理解的方法来链不同的异步计算在一起，使得它更容易比直接使用异步引入主题。

CompletableFuture[] futures = IntStream.rangeClosed(0, LEN).boxed()
            .map(i -> CompletableFuture.supplyAsync(() -> runStage1(i), EXECUTOR_SERVICE))
            .map(future -> future.thenCompose(i -> CompletableFuture.supplyAsync(() -> runStage2(i), EXECUTOR_SERVICE)))
            .toArray(size -> new CompletableFuture[size]);
CompletableFuture.allOf(futures).join();

第二

你永远不应该忘记处理异常；使用 CompletableFuture，您可以像这样直接处理它们：

completableFuture.handle((s, e) -> e.toString()).join()

或以这种方式利用它们来中断计算：

completableFuture.completeExceptionally(new RuntimeException("Calculation failed!"));

而使用Thread很容易遇到一些严重的问题。