Java CompletableFuture结果转换链式超时处理

在Java并发编程中，CompletableFuture是一个强大的工具，它提供了非阻塞的异步操作和结果处理。然而，在实际应用中，我们常常需要处理超时情况，并且希望在超时后进行特定的操作。本文将探讨如何通过链式调用实现CompletableFuture的结果转换和超时处理。

引言

在异步编程中，超时处理是一个常见的需求。传统的Future接口虽然提供了get(long timeout, TimeUnit unit)方法来处理超时，但其阻塞特性使得代码不够优雅。CompletableFuture则通过丰富的API支持更灵活的异步操作和结果处理。

CompletableFuture基础

CompletableFuture提供了多种方法来处理异步结果，例如：

thenApply：对结果进行转换
thenAccept：处理结果但不返回值
thenCompose：组合另一个异步操作

这些方法可以链式调用，使得代码更加简洁。

结果转换

假设我们有一个异步操作，返回一个字符串结果，我们希望将其转换为另一个类型。可以使用thenApply方法来实现：

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "Hello, World!");
CompletableFuture<Integer> lengthFuture = future.thenApply(String::length);

这里，thenApply将字符串结果转换为其长度。

超时处理

为了处理超时，CompletableFuture提供了orTimeout方法，但如果我们希望在超时后进行特定的操作，可以结合CompletableFuture的其他方法来实现。以下是一个示例：

public static <T> CompletableFuture<T> withTimeout(CompletableFuture<T> future, long timeout, TimeUnit unit, T defaultValue) {
    CompletableFuture<T> timeoutFuture = new CompletableFuture<>();
    Executors.newSingleThreadScheduledExecutor().schedule(() -> timeoutFuture.complete(defaultValue), timeout, unit);
    return future.applyToEither(timeoutFuture, Function.identity());
}

这个方法创建了一个新的CompletableFuture，在指定时间后完成，并返回默认值。然后使用applyToEither方法，哪个CompletableFuture先完成就使用其结果。

链式调用

结合结果转换和超时处理，我们可以实现一个链式调用的示例：

public static void main(String[] args) {
    CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
        try {
            Thread.sleep(1000); // 模拟耗时操作
            return "Hello, World!";
        } catch (InterruptedException e) {
            throw new IllegalStateException(e);
        }
    });

    CompletableFuture<Integer> resultFuture = withTimeout(future.thenApply(String::length), 500, TimeUnit.MILLISECONDS, -1);

    resultFuture.thenAccept(length -> System.out.println("Length: " + length))
                .exceptionally(ex -> {
                    System.out.println("Error: " + ex.getMessage());
                    return null;
                });
}

在这个示例中，我们首先创建一个异步操作，然后通过thenApply转换结果，接着使用withTimeout方法处理超时，最后通过thenAccept处理最终结果，并通过exceptionally处理可能的异常。