ExecutorService如何与CompletableFuture结合使用

ExecutorService 和 CompletableFuture 可以结合使用，以便在执行异步任务时更好地控制线程池和任务执行。以下是一个简单的示例，说明如何将它们结合在一起：

1. 首先，创建一个 ExecutorService 实例，它将用于管理线程池。

ExecutorService executorService = Executors.newFixedThreadPool(5);

2. 然后，使用 CompletableFuture.supplyAsync() 方法提交一个异步任务。这个方法接受一个 Supplier 函数式接口作为参数，并返回一个 CompletableFuture 实例。

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
    // 在这里执行你的异步任务
    return "Hello, World!";
}, executorService);

3. 接下来，你可以使用 thenApply()、thenAccept() 或 thenRun() 等方法来处理异步任务的结果。这些方法允许你在任务完成后执行一些操作，而无需阻塞主线程。

CompletableFuture<String> processedFuture = future.thenApply(result -> {
    // 对结果进行处理
    return result.toUpperCase();
});

4. 最后，当所有异步任务都完成时，记得关闭 ExecutorService。

executorService.shutdown();

这是一个完整的示例：

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class Main {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(5);

        CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
            // 在这里执行你的异步任务
            return "Hello, World!";
        }, executorService);

        CompletableFuture<String> processedFuture = future.thenApply(result -> {
            // 对结果进行处理
            return result.toUpperCase();
        });

        processedFuture.thenAccept(System.out::println);

        executorService.shutdown();
    }
}

在这个示例中，我们创建了一个固定大小的线程池，提交了一个异步任务，将结果转换为大写，然后打印出来。最后，我们关闭了 ExecutorService。