java CompletableFuture 详解

桃扇骨 2024-03-24 10:16 69阅读 0赞

Java CompletableFuture是Java 8中新增加的异步编程工具，可以用于处理异步任务，并在任务完成后进行处理。它是一种类似于Promise的概念，在Java中广泛使用。

**CompletableFuture的主要特点：**

1.  支持异步编程
2.  支持链式调用
3.  支持组合多个CompletableFuture
4.  支持异常处理
5.  支持超时处理
6.  支持取消操作

CompletableFuture的使用方式：

创建CompletableFuture对象

CompletableFuture future = new CompletableFuture<>();

执行异步任务

CompletableFuture.supplyAsync(() -> "Hello").thenApply(s -> s + " World");

处理任务结果

CompletableFuture future = CompletableFuture.supplyAsync(() -> "Hello"); future.thenAccept(result -> System.out.println(result));

处理任务异常

CompletableFuture future = CompletableFuture.supplyAsync(() -> {
        throw new RuntimeException("Error");
    });
    future.exceptionally(ex -> "Error occurred");

组合多个CompletableFuture

CompletableFuture future1 = CompletableFuture.supplyAsync(() -> "Hello"); 
      CompletableFuture future2 = CompletableFuture.supplyAsync(() -> "World"); 
      CompletableFuture future3 = future1.thenCombine(future2, (s1, s2) -> s1 + " " + s2);

超时处理

CompletableFuture future = CompletableFuture.supplyAsync(() -> {
                try {
                    Thread.sleep(5000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                return "Hello";
            });
            future.orTimeout(3, TimeUnit.SECONDS);

取消操作

CompletableFuture future =
                    CompletableFuture.supplyAsync(() -> {
                        try {
                            Thread.sleep(5000);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                        return "Hello";
                    });
            future.cancel(true);

总结：

CompletableFuture是Java 8中新增加的异步编程工具，可以用于处理异步任务，并在任务完成后进行处理。它支持链式调用、组合多个CompletableFuture、异常处理、超时处理和取消操作等特性。使用CompletableFuture可以让我们更加方便地处理异步任务，提高程序的性能和可读性。