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提供了更现代的异步编程模型。
