为什么 CompletableFuture 的 thenAccept() 不是主线程上的 运行

Question

我在 CompletableFuture 的 supplyAsync() 中处理长 运行ning 操作，并将结果放入 thenAccept()。有时 thenAccept() 在主线程上执行，但有时它 运行 在工作线程上执行 thread.But 我希望 运行 thenAccept() 操作仅在主线程上执行。这是示例代码。

private void test() {

    ExecutorService executorService = Executors.newSingleThreadExecutor();

    CompletableFuture<String> cf1 = CompletableFuture.supplyAsync(() -> {
        System.out.println("supplyAsync | I am running on : " + Thread.currentThread().getName());
        return "Hello world";
    }, executorService);

    CompletableFuture<Void> cf3 = cf1.thenAccept(s -> {
        System.out.print("thenAccept | I am running on : " + Thread.currentThread().getName());
        System.out.println(" | answer : " + s);
    });

    cf3.thenRun(() -> {
        System.out.println("thenRun | I am running on : " + Thread.currentThread().getName());
        System.out.println();
    });

}

public static void main(String[] args) {

    App app = new App();
    for(int i = 0; i < 3; i++){
        app.test();
    }
}

结果是：

supplyAsync | I am running on : pool-1-thread-1
thenAccept | I am running on : main | answer : Hello world
thenRun | I am running on : main

supplyAsync | I am running on : pool-2-thread-1
thenAccept | I am running on : main | answer : Hello world
thenRun | I am running on : main

supplyAsync | I am running on : pool-3-thread-1
thenAccept | I am running on : pool-3-thread-1 | answer : Hello world
thenRun | I am running on : pool-3-thread-1

我该如何解决这个问题？

Answer 1

查看 CompletableFuture 的 Java 文档。有趣的部分是关于 CompletionStage 政策的部分。

您会发现使用 非异步 方法会导致一种非此即彼的情况。如果您随后查看实现，您将最终进入 Java 运行时的非 public 部分。有一些 UNSAFE 处理意味着可能会发生某种竞争条件。

我建议使用 thenAcceptAsync() 和 thenRunAsync() 变体并传递您的 executorService 两个调用的变量。