Java CompletableFuture异步超时处理的艺术

在当今快节奏的软件开发中，异步编程已成为提高应用程序性能和响应速度的关键技术。Java 8引入的CompletableFuture为异步编程提供了强大的支持，但如何在异步操作中优雅地处理超时问题，依然是一个值得探讨的话题。

异步编程的挑战

异步编程的核心优势在于非阻塞，它允许程序在等待长时间操作（如网络请求、数据库查询）完成时，继续执行其他任务。然而，异步操作的超时处理却是一个棘手的问题。如果处理不当，可能会导致资源泄漏、程序卡死等问题。

`CompletableFuture`简介

CompletableFuture是Java 8引入的一个强大的异步编程工具，它提供了丰富的API来处理异步任务。通过CompletableFuture，我们可以轻松地实现任务的链式调用、异常处理和结果合并。

超时处理的几种方式

使用`CompletableFuture`的`orTimeout`方法

Java 9引入了CompletableFuture的orTimeout方法，可以方便地设置超时时间。如果任务在指定时间内未完成，将抛出TimeoutException。

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
    // 模拟长时间任务
    try {
        Thread.sleep(5000);
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
    }
    return "Result";
});

future.orTimeout(3, TimeUnit.SECONDS)
       .exceptionally(ex -> "Timeout occurred: " + ex.getMessage())
       .thenAccept(System.out::println);

使用`CompletableFuture`的`completeOnTimeout`方法

Java 9还引入了completeOnTimeout方法，它在任务超时时不会抛出异常，而是返回一个默认值。

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
    // 模拟长时间任务
    try {
        Thread.sleep(5000);
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
    }
    return "Result";
});

future.completeOnTimeout("Default Result", 3, TimeUnit.SECONDS)
       .thenAccept(System.out::println);

自定义超时处理

在Java 8及以下版本中，我们可以通过自定义方式来实现超时处理。利用ScheduledExecutorService来设置一个定时任务，如果主任务未在指定时间内完成，则通过completeExceptionally方法抛出异常。

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
    // 模拟长时间任务
    try {
        Thread.sleep(5000);
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
    }
    return "Result";
});

ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
scheduler.schedule(() -> {
    if (!future.isDone()) {
        future.completeExceptionally(new TimeoutException("Operation timed out"));
    }
}, 3, TimeUnit.SECONDS);

future.exceptionally(ex -> "Timeout occurred: " + ex.getMessage())
       .thenAccept(System.out::println);

scheduler.shutdown();