主线程在完成完全未来之前退出

Question

    CompletableFuture feature = CompletableFuture.supplyAsync (() ->       composeMethod ( )).
            thenAccept (s -> System.out.println ("wassup java" + s)).
            thenRun (() -> System.out.println (" imm immortal"));
    nonblockingmethod ( );

这是我正在研究的完全未来的例子

private static void nonblockingmethod() {
        System.out.println ("why  should i wait for you ");
    }

    private static String composeMethod() {
        try {
            TimeUnit.MILLISECONDS.sleep (3);
            File file = Paths.get ("/Users/solo/solo1.txt").toFile ( );

            if (!file.exists ( )) {
                file.createNewFile ( );
            }

        } catch (Exception e) {

        }
        return "   resultdaa";
    }

首先我从SupplySync调用compose方法，在这里我执行方法composeMethod，有三毫秒的延迟，然后它将创建一个文件并返回一个字符串作为结果。完成后，我调用Run方法，它只打印一个方法，然后有一个非阻塞方法从主线程运行。

我在这里面临的问题是，主线程执行完nonblockingmethod（）并在3毫秒延迟之前退出进程，而随后的composeMethod操作则是如此。这是预期的行为还是我必须使用get或join阻止主线程，或者我错过了任何东西

Answer 1

supplyAsync中提供的任务将在ForkJoinPool#commonPool中执行。如果您查看公共池中的线程，您可以看到它们是Deamon线程，这意味着当没有活动的非守护线程时，JVM不会等待守护线程关闭以完成其执行。在您的例子中，您在composeMethod中有一个睡眠，同时，主线程执行并完成其工作，JVM没有任何活动的非守护进程线程。因此，JVM将转到关闭，而无需等待任务完成。如果运行下面的示例，您可以确认线程池和线程类型。

CompletableFuture feature = CompletableFuture.supplyAsync(() -> {
    System.out.println("Thread : " + Thread.currentThread());
    System.out.println("Is Daemon : " + Thread.currentThread().isDaemon());
    return composeMethod();
}).thenAccept(s -> System.out.println("wassup java" + s)).thenRun(() -> System.out.println(" imm immortal"));

输出：

Thread : Thread[ForkJoinPool.commonPool-worker-1,5,main] // This line may be bit different but it indicates that your task is executing on Common pool
Is Daemon : true
why  should i wait for you 

要解决问题，您可以通过自己的执行人，如下所示：

ExecutorService executorService = Executors.newFixedThreadPool(8);
CompletableFuture feature = CompletableFuture.supplyAsync(() -> {
        System.out.println("Thread : " + Thread.currentThread());
        System.out.println("Is Daemon : " + Thread.currentThread().isDaemon());
        return composeMethod();
    }, executorService).thenAccept(s -> System.out.println("wassup java" + s))
            .thenRun(() -> System.out.println(" imm immortal"));
executorService.shutdown();
nonblockingmethod();

输出：

Thread : Thread[pool-1-thread-1,5,main]
Is Daemon : false
why  should i wait for you 
wassup java   resultdaa
 imm immortal