完全可执行的未来执行顺序

Question

我试图理解java中完整期货的非阻塞回调性质

 CompletableFuture.supplyAsync(() -> {
        try {
            //Thread.sleep(20000);
            System.out.println("supplyAsync Thread name " + Thread.currentThread().getName());
            return "str";

        } catch (Exception e) {
            return "";
        }


    }).thenApply(str -> {
        System.out.println("thenApply Thread name " + Thread.currentThread().getName());
        return str;
    }).thenApply(str1 -> {
        System.out.println("thenApply Thread name " + Thread.currentThread().getName());
        return str1;
    }).thenAccept(str3 -> {
        System.out.println("thenAccept Thread name " + Thread.currentThread().getName());
    });
    System.out.println("Thread name " + Thread.currentThread().getName());

有了上面的代码，我总是看到下面看到的输出

线程名称ForkJoinPool.common池工人-1
thenApply Thread name main
thenApply Thread name main
thenAcceptThread name main
Thread name main

这个顺序似乎建议主线程等待所有Futures线程的执行。
我试图将Thread.sleep添加到供应Async方法，输出是

主线程名称

futures线程中的print语句似乎都未执行。我对非阻塞的理解是能够打印

线程名称主SupplySync线程名称
ForkJoinPool。commonPool-worker-1
然后应用线程名称main
然后应用线程名称main
然后接受线程名称main

如果在Javascript中执行类似的代码，则可以执行上述控制台输出

在Java中是否可以实现上述功能？

Answer 1

不，它没有阻塞。默认情况下，completable future在ForkJoinPool上执行其任务。commonPool其中commonPool的线程是守护进程，意思是线程。当主线程完成其执行时，JVM将终止池中所有其他守护进程线程，这就是为什么在第二种情况下，您只看到threadname Main。

然而，你可以通过自己的执行者来完成未来。

CompletableFuture.supplyAsync(() -> {
            try {
                Thread.sleep(2000);
                System.out.println("supplyAsync Thread name " + Thread.currentThread().getName());
                System.out.println("Is daemon Thread: " + Thread.currentThread().isDaemon());
                return "str";

            } catch (Exception e) {
                return "";
            }

        }, Executors.newFixedThreadPool(4)).thenApply(str -> {
            System.out.println("thenApply Thread name " + Thread.currentThread().getName());
            return str;
        }).thenApply(str1 -> {
            System.out.println("thenApply Thread name " + Thread.currentThread().getName());
            return str1;
        }).thenAccept(str3 -> {
            System.out.println("thenAccept Thread name " + Thread.currentThread().getName());
        });
        System.out.println("Thread name " + Thread.currentThread().getName());

如果运行上述代码，您可以得到如下输出：

Thread name main
supplyAsync Thread name pool-1-thread-1
Is daemon Thread: false
thenApply Thread name1 pool-1-thread-1
thenApply Thread name1 pool-1-thread-1
thenAccept Thread name1 pool-1-thread-1