Java ExecutorService如何实现任务超时处理

在Java中，使用ExecutorService执行任务时，可以通过Future对象的get方法设置超时时间来处理任务超时。以下是一个简单的示例：

import java.util.concurrent.*;

public class ExecutorServiceTimeoutExample {
    public static void main(String[] args) {
        // 创建一个固定大小的线程池
        ExecutorService executorService = Executors.newFixedThreadPool(2);

        // 提交任务并获取Future对象
        Future<?> future = executorService.submit(() -> {
            try {
                System.out.println("任务开始执行");
                Thread.sleep(5000); // 模拟任务耗时5秒
                System.out.println("任务执行完毕");
            } catch (InterruptedException e) {
                System.out.println("任务被中断");
            }
        });

        try {
            // 设置超时时间为3秒
            future.get(3, TimeUnit.SECONDS);
        } catch (InterruptedException e) {
            System.out.println("主线程被中断");
            future.cancel(true); // 取消任务
        } catch (ExecutionException e) {
            System.out.println("任务执行异常");
        } catch (TimeoutException e) {
            System.out.println("任务超时");
            future.cancel(true); // 取消任务
        } finally {
            executorService.shutdown(); // 关闭线程池
        }
    }
}

在这个示例中，我们创建了一个固定大小的线程池，并提交了一个耗时5秒的任务。然后，我们使用future.get(3, TimeUnit.SECONDS)设置了3秒的超时时间。如果任务在3秒内没有完成，将抛出TimeoutException异常，我们可以捕获这个异常并取消任务。最后，记得关闭线程池。