Java并发编程之CompletableFuture

2024-07-09 15:05:42 浏览数 (3)

CompletableFuture 是 Java 8 中引入的一个类，用于支持异步编程和非阻塞式的操作。它提供了一种简洁的方式来处理异步计算的结果。使用 CompletableFuture，可以以函数式的方式组合多个异步操作，从而更容易地编写并发代码。 CompletableFuture，它不仅实现了Future接口，还提供了丰富的API来支持异步编程。开发者可以更优雅地处理异步任务的执行、结果处理和异常处理。 CompletableFuture提供了诸如thenApply、thenAccept、thenCombine等方法，可以轻松地将多个异步任务串联或并行执行，并在任务完成后进行回调处理。 CompletableFuture还支持自定义线程池，使得开发者可以灵活地管理线程资源，提高程序的并发性能和可维护性。

功能详解

CompletableFuture专注于异步任务的结果，并提供丰富的 API 用于组合和错误处理。它负责：

  • 并行处理：可以将多个独立的任务并行执行，然后合并结果。
  • 异步回调：可以在任务完成后执行回调函数，而不阻塞主线程。
  • 异常处理：在异步操作中更方便地处理异常情况。

简单示例

以下代码演示了在 Java 中使用来CompletableFuture处理异步计算。

代码语言：javascript复制
public static void main(String[] args) {  
    CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {  
        System.out.println("Hello,FunTester! "   Thread.currentThread().getName());  
        return "Hello,FunTester!";  
    });  
    future.thenAccept(System.out::println);  
    future.join();  
}

这个示例代码展示了如何使用Java的CompletableFuture类来异步执行任务,并处理任务的结果。让我们逐步解析一下:

  1. CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {...});这一行创建了一个CompletableFuture实例,并使用supplyAsync方法异步执行提供的lambda表达式。lambda表达式的代码块中,首先打印了一个字符串和当前线程名称,然后返回字符串"Hello,FunTester!"。
  2. future.thenAccept(System.out::println);这一行注册了一个回调函数,当上一步异步任务完成时,它会将任务的结果(即字符串"Hello,FunTester!"传递给System.out::println方法,从而将其打印到控制台。
  3. future.join();这一行是一个阻塞操作,它会等待异步任务完成。如果异步任务已经完成,则立即返回;否则,它会一直等待直到异步任务完成。

因此,运行这个程序时,它会先打印"Hello,FunTester! [线程名称]"(这是在异步任务中打印的),然后打印"Hello,FunTester!"(这是由thenAccept回调打印的)。

这个示例展示了CompletableFuture如何简化异步编程。你可以使用lambda表达式来定义异步任务,并使用thenAccept等方法来注册对任务结果的处理逻辑。CompletableFuture还提供了其他有用的方法,如thenApply、thenCompose等,用于组合和链式执行多个异步任务。

链式异步任务

CompletableFuture的强大功能之一就是能够将多个异步任务链接在一起。处理复杂的异步工作流时，这可以使代码更具可读性和可维护性。 以下代码演示了如何CompletableFuture在 Java 中使用链接多个任务来创建一系列异步计算。

代码语言：javascript复制
import java.util.concurrent.CompletableFuture;
 
public class ChainingTasksExample {
    public static void main(String[] args) {
        CompletableFuture.supplyAsync(() -> "Task 1")
            .thenApply(result -> result   "   Task 2")
            .thenApply(result -> result   "   Task 3")
            .thenAccept(System.out::println);
    }
}

这个案例中展示了CompletableFuture的链式调用和结果转换的用法。让我们逐步解析一下:

  1. CompletableFuture.supplyAsync(() -> "Task 1")
  • 这一行创建了一个CompletableFuture实例,并使用supplyAsync方法异步执行一个lambda表达式,该表达式返回字符串"Task 1"。
  1. .thenApply(result -> result " Task 2")
  • thenApply方法接受一个函数式接口Function作为参数,该函数接收上一个任务的结果作为输入,并返回一个新的结果。
  • 在这里,lambda表达式result -> result " Task 2"将上一个任务的结果("Task 1")与字符串" Task 2"连接,返回"Task 1 Task 2"。
  1. .thenApply(result -> result " Task 3")
  • 这一行又使用thenApply方法,将上一个任务的结果("Task 1 Task 2")与字符串" Task 3"连接,返回"Task 1 Task 2 Task 3"。
  1. .thenAccept(System.out::println);
  • thenAccept方法接受一个函数式接口Consumer作为参数,该接口消费上一个任务的结果,但不返回任何值。
  • 在这里,使用System.out::println方法引用作为Consumer的实现,它将打印上一个任务的结果("Task 1 Task 2 Task 3")。

因此,当你运行这个代码时,它会异步执行三个任务,每个任务在上一个任务的结果上追加一个字符串。最终,它会将最终的结果"Task 1 Task 2 Task 3"打印到控制台。

这个示例展示了CompletableFuture如何通过链式调用和结果转换来组合多个异步任务。每个thenApply方法都会在上一个任务完成后异步执行,并将结果传递给下一个任务。最后,thenAccept方法用于消费最终的结果

错误处理

CompletableFuture提供了多种方法来处理异步任务执行过程中发生的异常。您可以使用exceptionally、handle和等方法whenComplete来妥善处理错误。

以下代码演示了在使用CompletableFutureJava 时如何正确处理错误。

代码语言：javascript复制
import java.util.concurrent.CompletableFuture;
 
public class ErrorHandlingExample {
    public static void main(String[] args) {
        CompletableFuture.supplyAsync(() -> {
            if (true) throw new RuntimeException("Something went wrong!");
            return "Success";
        }).exceptionally(ex -> {
            System.out.println("Error: "   ex.getMessage());
            return "Fallback result";
        }).thenAccept(System.out::println);
    }
}

超时管理

在异步编程中，管理超时至关重要，以避免无限期地等待任务完成。提供和CompletableFuture等方法来有效地处理超时。

以下代码演示了如何CompletableFuture在 Java 中管理超时。

代码语言：javascript复制
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.TimeUnit;
 
public class TimeoutManagementExample {
    public static void main(String[] args) {
        CompletableFuture.supplyAsync(() -> {
                    try {
                        TimeUnit.SECONDS.sleep(5);
                    } catch (InterruptedException e) {
                        throw new IllegalStateException(e);
                    }
                    return "Result after delay";
                }).orTimeout(2, TimeUnit.SECONDS)
                .exceptionally(ex -> "Timeout occurred")
                .thenAccept(System.out::println);
    }
}

这个例子演示了如何使用CompletableFuture的orTimeout方法来设置异步任务的超时时间,以及如何在超时发生时进行处理。让我们逐步分析一下:

  1. CompletableFuture.supplyAsync(() -> { ... })
  • 这一行创建了一个CompletableFuture实例,并使用supplyAsync方法异步执行提供的lambda表达式。
  • 在该lambda表达式中,代码调用TimeUnit.SECONDS.sleep(5)故意让任务休眠5秒钟,模拟一个耗时操作。
  1. .orTimeout(2, TimeUnit.SECONDS)
  • orTimeout方法设置了异步任务的超时时间为2秒。如果任务在2秒内未完成,则会触发超时并返回一个TimeoutException。
  1. .exceptionally(ex -> "Timeout occurred")
  • exceptionally方法接受一个函数式接口Function作为参数,该函数接收异步任务抛出的异常作为输入,并返回一个备用结果。
  • 在这里,lambda表达式ex -> "Timeout occurred"接收到异常实例ex后,返回字符串"Timeout occurred"作为备用结果。
  1. .thenAccept(System.out::println);
  • thenAccept方法接受一个函数式接口Consumer作为参数,该接口消费上一个任务的结果,但不返回任何值。
  • 在这里,使用System.out::println方法引用作为Consumer的实现,它将打印上一个任务的结果(即备用结果"Timeout occurred"或成功结果"Result after delay"(如果任务在2秒内完成))。

当我们运行这个程序时,由于异步任务会休眠5秒钟,而超时时间设置为2秒钟,因此会触发超时。exceptionally方法会被调用,并返回备用结果"Timeout occurred"给thenAccept方法,最终被打印到控制台。

输出应该是:

代码语言：javascript复制
Timeout occurred

如果将超时时间设置为大于5秒,例如orTimeout(6, TimeUnit.SECONDS)，那么输出将是:

代码语言：javascript复制
Result after delay

这个示例展示了如何使用orTimeout方法来设置CompletableFuture的超时时间,以及如何使用exceptionally方法来处理超时情况。在一些需要控制任务执行时间的场景中,这个功能非常有用,可以防止任务无限期地阻塞或占用资源。

java 并发编程 函数 异步 字符串

0 人点赞