CompletableFuture 设置 阻塞线程

CompletableFuture可以通过get()方法来阻塞线程，直到异步任务执行完成并返回结果。下面是一个例子：

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
    try {
        Thread.sleep(1000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    return "Hello";
});

try {
    String result = future.get(); // 阻塞线程，直到异步任务执行完成并返回结果
    System.out.println(result); // 输出：Hello
} catch (InterruptedException | ExecutionException e) {
    e.printStackTrace();
}

在上面的例子中，我们使用supplyAsync()方法开启了一个异步任务，该任务会在1秒后返回字符串"Hello"。然后我们调用了future.get()方法来阻塞线程，直到异步任务执行完成并返回结果。最后我们输出了异步任务的结果"Hello"。

相关问题

CompletableFuture线程阻塞

CompletableFuture是Java 8中引入的一个类，用于支持异步编程。该类提供了一系列的方法，用于处理异步任务的完成、组合和异常处理等操作。

在引用的代码中，使用了CompletableFuture的allOf方法来等待多个异步任务完成。allOf方法会返回一个新的CompletableFuture对象，当所有的异步任务都完成时，该对象的结果才会被设置，否则会一直阻塞。

在引用中提到，可以使用CompletableFuture的completedFuture静态方法来创建一个已经完成的CompletableFuture对象。

在引用中提到了异常处理。使用静态方法创建的CompletableFuture对象无需显示处理异常，而使用new创建的对象需要调用completeExceptionally方法来设置捕获到的异常。

综上所述，CompletableFuture可以实现线程的阻塞和异步任务的处理。

CompletableFuture里的线程id 为何一直增加，而不是复用以前的对象？

这是因为CompletableFuture使用了ForkJoinPool来执行异步任务，而ForkJoinPool的设计是为了充分利用CPU资源，因此会创建新的线程来执行任务，而不是复用以前的线程。这样可以避免线程的竞争和阻塞，提高程序的并发性能。