Javaでタスクのタイムアウト処理を実装する方法

1年 ago
綾乃, 一希
1 minute

Javaはスレッドを使用してタスクのタイムアウト処理を実現できます。以下に簡単な例を示します。

import java.util.concurrent.*;
public class TimeoutExample {
public static void main(String[] args) {
ExecutorService executor = Executors.newSingleThreadExecutor();
// 创建一个Callable任务
Callable<String> task = () -> {
// 模拟一个耗时的操作
Thread.sleep(5000);
return "Task completed";
};
try {
// 提交任务并设置超时时间为2秒
Future<String> future = executor.submit(task);
String result = future.get(2, TimeUnit.SECONDS);
System.out.println(result);
} catch (TimeoutException e) {
// 超时处理
System.out.println("Task timeout");
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
} finally {
executor.shutdownNow(); // 关闭线程池
}
}
}

上記例では、単一スレッドのスレッドプールを作成し、時間を要するタスクを１つ送信します。タスクの結果を取得するには、Futureオブジェクトのgetメソッドを使用して、タイムアウト時間として２秒を設定しました。タスクがタイムアウト時間内に完了しない場合、TimeoutExceptionが発生し、catchブロックでその旨の処理を行うことができます。最後に、shutdownNowメソッドを呼び出してスレッドプールを終了することをお忘れなく。

bannerAds