是否可以在创建它的同一线程中运行一个可完成的未来？

Question

想知道 completablefuture 是否可以在创建它的线程中运行。您可能会问为什么我需要这样做，因为 completablefuture 是用于异步编程的。原因是我有一些异步任务和一些我想在生成线程中运行的任务，以便我可以使用 allOf 等并保持代码的一致性

Answer 1

当你说你想知道“一个完整的未来是否可以在创建它的线程中运行”时，你表现出了错误的心态。ACompletableFuture不运行。ACompletableFuture只是封装了一个值或者异常，最多可以设置一次，我们称之为完成它。

\n\n

API 提供了许多用于安排完成尝试的方法（可能是异步的），但您不应该因决定如何完成它而分心。

\n\n

异步完成有一些简单的替代方案：

\n\n

CompletableFuture<String> f = CompletableFuture.completedFuture("hello");\n

\n\n

创造一个立即完成的未来。Java\xc2\xa09 添加failedFuture对创建立即异常完成的未来的支持。

\n\n

您还可以轻松创建一个稍后在同一线程中完成的 future：

\n\n

CompletableFuture<String> f = new CompletableFuture<>();\n\n// arbitrary actions\n\nf.complete("hello");\n

\n\n

您还可以将工厂方法与执行器一起使用，立即在启动线程中运行操作：

\n\n

CompletableFuture<String> f\n  = CompletableFuture.supplyAsync(() -> "hello", Runnable::run);\n

\n\n

或者

\n\n

CompletableFuture<String> f\n  = CompletableFuture.supplyAsync(() -> {\n    if(Math.random() > 0.5) throw new IllegalStateException();\n    return "hello";\n  }, Runnable::run);\n

\n\n

演示与调用的区别complete或创建立即完成的未来的区别。

\n\n

当然，这些可能性可以与其他功能相结合，例如allOf：

\n\n

CompletableFuture<String> a = new CompletableFuture<>();\nCompletableFuture<String> b = new CompletableFuture<>();\nCompletableFuture<String> c = new CompletableFuture<>();\n\nCompletableFuture.allOf(a, b, c).whenComplete((__, t) -> {\n  if(t != null) System.err.println("failed with "+t);\n  else System.out.println("all completed "+a.join()+", "+b.join()+", "+c.join());\n});\n\nSystem.out.println("step 1");\na.complete("foo");\nSystem.out.println("step 2");\nb.complete("bar");\nSystem.out.println("step 3");\nc.complete("baz");\n

\n