如何使用Java ExecutorService实现任务超时控制

在Java中，你可以使用ExecutorService结合Future和Callable来实现任务的超时控制。以下是一个简单的示例：

1. 首先，导入所需的包：

import java.util.concurrent.*;

2. 创建一个实现了Callable接口的任务类：

class MyTask implements Callable<String> {
    @Override
    public String call() throws Exception {
        // 模拟一个耗时任务
        Thread.sleep(5000);
        return "任务完成";
    }
}

3. 使用ExecutorService提交任务并获取Future对象：

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

        // 提交任务并获取Future对象
        Future<String> future = executorService.submit(new MyTask());

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

在这个示例中，我们创建了一个固定大小的线程池，并提交了一个实现了Callable接口的任务。然后，我们使用future.get()方法设置超时时间。如果在指定的时间内任务没有完成，将抛出TimeoutException异常。最后，我们关闭线程池。