Java ExecutorService与CompletableFuture结合使用

Java中的ExecutorService和CompletableFuture可以很好地结合使用，以便在异步编程中实现更高级的功能。ExecutorService是一个接口，它提供了一种将任务提交给线程池执行的方法。而CompletableFuture是一个类，它表示一个异步计算的结果，可以在计算完成时执行某些操作。

以下是如何将ExecutorService与CompletableFuture结合使用的示例：

1. 首先，创建一个ExecutorService实例，例如使用Executors.newFixedThreadPool()方法创建一个固定大小的线程池。

ExecutorService executorService = Executors.newFixedThreadPool(5);

2. 使用CompletableFuture.supplyAsync()方法提交一个异步任务。这个方法接受一个Supplier函数式接口作为参数，该接口的get()方法将返回计算结果。supplyAsync()方法还接受一个Executor参数，用于指定执行任务的线程池。

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
    // 在这里执行耗时操作
    return "Hello, World!";
}, executorService);

3. 使用thenApply()、thenAccept()或thenRun()等方法处理异步任务的结果。这些方法都返回一个新的CompletableFuture，可以链式调用。

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

4. 使用join()或get()方法等待异步任务完成并获取结果。

String result = processedFuture.join();
System.out.println(result); // 输出 "HELLO, WORLD!"

5. 最后，记得关闭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();
        });

        String result = processedFuture.join();
        System.out.println(result); // 输出 "HELLO, WORLD!"

        executorService.shutdown();
    }
}

通过这种方式，你可以充分利用ExecutorService和CompletableFuture的优势，实现更高效、可扩展的异步编程。