在Java编程中，异步编程是一种常用的技术，它可以帮助我们提高程序的响应性，尤其是在处理耗时的操作时。CompletableFuture是Java 8引入的一个强大的工具，它简化了异步编程的复杂性。本文将深入探讨CompletableFuture的回调机制，帮助读者轻松掌握这一Java异步编程利器。

CompletableFuture简介

CompletableFuture是一个可以表示异步计算结果的容器。它类似于Future，但提供了更丰富的功能，如方法链式调用、异常处理、结果组合等。使用CompletableFuture，我们可以轻松地构建复杂的异步流程。

回调机制

CompletableFuture的核心在于其回调机制。它允许我们在异步任务完成时执行特定的操作。这种机制使得异步编程变得更加直观和易于管理。

1. thenApply

thenApply方法允许我们在异步任务完成后执行一个函数，并将结果传递给下一个异步任务。以下是一个简单的例子：

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "Hello");
future.thenApply(s -> s + " World").thenAccept(System.out::println);

在这个例子中，我们首先使用supplyAsync创建一个异步任务，该任务返回字符串"Hello"。然后，我们使用thenApply将"Hello"和" World"连接起来，最后使用thenAccept将结果打印到控制台。

2. thenRun

thenRun方法允许我们在异步任务完成后执行一个无参数的函数。以下是一个例子：

CompletableFuture.supplyAsync(() -> {
    // 模拟耗时操作
    try {
        Thread.sleep(1000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    return "Done";
}).thenRun(() -> System.out.println("异步任务完成"));

在这个例子中，我们使用thenRun在异步任务完成后打印一条消息。

3. thenAccept

thenAccept方法允许我们在异步任务完成后接收一个结果，但不返回任何值。以下是一个例子：

CompletableFuture.supplyAsync(() -> {
    // 模拟耗时操作
    try {
        Thread.sleep(1000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    return "Result";
}).thenAccept(result -> System.out.println("异步任务结果：" + result));

在这个例子中，我们使用thenAccept打印异步任务的结果。

4. thenCompose

thenCompose方法允许我们将一个异步任务的结果作为另一个异步任务的输入。以下是一个例子：

CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> "A");
CompletableFuture<String> future2 = future1.thenCompose(s -> {
    return CompletableFuture.supplyAsync(() -> s + "B");
});
future2.thenAccept(System.out::println);

在这个例子中，我们首先创建一个异步任务future1，然后使用thenCompose创建另一个异步任务future2，该任务将future1的结果与"B"连接起来。

异常处理

在异步编程中，异常处理是一个重要的环节。CompletableFuture提供了多种方法来处理异常。

1. exceptionally

exceptionally方法允许我们在异步任务抛出异常时执行一个函数。以下是一个例子：

CompletableFuture.supplyAsync(() -> {
    // 模拟异常
    throw new RuntimeException("Error");
}).exceptionally(ex -> {
    System.out.println("异常处理：" + ex.getMessage());
    return "Error";
}).thenAccept(System.out::println);

在这个例子中，我们使用exceptionally来处理异步任务抛出的异常。

2. handle

handle方法允许我们在异步任务完成或抛出异常时执行一个函数。以下是一个例子：

CompletableFuture.supplyAsync(() -> {
    // 模拟异常
    throw new RuntimeException("Error");
}).handle((result, ex) -> {
    if (ex != null) {
        System.out.println("异常处理：" + ex.getMessage());
        return "Error";
    }
    return result;
}).thenAccept(System.out::println);

在这个例子中，我们使用handle来处理异步任务完成或抛出异常的情况。

总结

CompletableFuture是Java异步编程的利器，它提供了丰富的回调机制和异常处理方法。通过本文的介绍，相信读者已经对CompletableFuture有了更深入的了解。在实际开发中，熟练掌握CompletableFuture将有助于我们编写更高效、更易于维护的异步程序。