java如何执行超时

如何实现Java中的超时执行

在Java中，可以通过多种方式实现代码执行的超时控制。以下是几种常见的方法：

使用Future和ExecutorService

通过ExecutorService提交任务，并使用Future的get方法设置超时时间：

ExecutorService executor = Executors.newSingleThreadExecutor();
Future<String> future = executor.submit(() -> {
    // 长时间运行的任务
    return "结果";
});

try {
    String result = future.get(5, TimeUnit.SECONDS); // 设置5秒超时
} catch (TimeoutException e) {
    future.cancel(true); // 取消任务
} finally {
    executor.shutdown();
}

使用CompletableFuture

Java 8引入的CompletableFuture也支持超时：

CompletableFuture.supplyAsync(() -> {
    // 长时间运行的任务
    return "结果";
}).orTimeout(5, TimeUnit.SECONDS) // 设置5秒超时
  .exceptionally(ex -> "超时处理");

使用Thread和interrupt

通过创建线程并设置中断：

Thread thread = new Thread(() -> {
    while (!Thread.currentThread().isInterrupted()) {
        // 执行任务
    }
});
thread.start();

try {
    thread.join(5000); // 等待5秒
    if (thread.isAlive()) {
        thread.interrupt(); // 中断线程
    }
} catch (InterruptedException e) {
    Thread.currentThread().interrupt();
}

使用Guava的SimpleTimeLimiter

Google Guava库提供了TimeLimiter工具：

TimeLimiter limiter = SimpleTimeLimiter.create(Executors.newSingleThreadExecutor());
try {
    limiter.callWithTimeout(() -> {
        // 长时间运行的任务
        return "结果";
    }, 5, TimeUnit.SECONDS);
} catch (TimeoutException e) {
    // 处理超时
}

使用ScheduledExecutorService

通过ScheduledExecutorService安排超时检查：

ExecutorService executor = Executors.newSingleThreadExecutor();
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);

Future<String> future = executor.submit(() -> {
    // 长时间运行的任务
    return "结果";
});

scheduler.schedule(() -> {
    future.cancel(true);
}, 5, TimeUnit.SECONDS);

每种方法适用于不同场景，选择时应考虑任务的特性、资源消耗和精确度要求。Future和ExecutorService组合是最常用的方式，而CompletableFuture提供了更现代的异步编程模型。