✅线程池中怎么设置超时时间？一个线程如果要运行10s，怎么在1s就抛出异常
典型回答
在使用线程池时，如果希望设置线程的超时时间，并在超时后抛出异常，可以根据不同的线程池实现方式和任务管理策略进行设置。常见的Java线程池实现包括 ExecutorService 和 ScheduledExecutorService，以及如何使用 Future 和 Callable 来控制任务执行和超时。
使用Future设置超时时间
在Java中，可以使用 ExecutorService 来执行任务，并通过 Future.get(long timeout, TimeUnit unit) 方法设置超时。如果任务在指定的时间内未完成，会抛出 TimeoutException 异常。
import java.util.concurrent.*;
public class ThreadPoolTimeoutExample {
public static void main(String[] args) {
// 创建一个线程池
ExecutorService executor = Executors.newFixedThreadPool(2);
// 创建一个Callable任务
Callable<String> task = () -> {
// 模拟执行10秒的任务
Thread.sleep(10000);
return "Task completed";
};
// 提交任务并获取Future对象
Future<String> future = executor.submit(task);
try {
// 设置任务的超时时间为1秒
String result = future.get(1, TimeUnit.SECONDS); // 1秒超时
System.out.println(result);
} catch (TimeoutException e) {
System.out.println("Task timed out!");
future.cancel(true); // 取消任务
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
} finally {
executor.shutdown();
}
}
}通过 **ScheduledExecutorService** 设置任务超时
ScheduledExecutorService 是一个可以来定期或延迟执行任务的工具，他的schedule(Callable<V> callable, long delay, TimeUnit unit);方法，可以设置延迟执行，然后在延迟的时间执行中，调用cancel方法取消任务即可。
import java.util.concurrent.*;
public class ScheduledThreadPoolTimeoutExample {
public static void main(String[] args) {
ScheduledExecutorService executor = Executors.newScheduledThreadPool(2);
Callable<String> task = new Callable<String>() {
@Override
public String call() throws Exception {
Thread.sleep(10000); // 模拟任务运行时间
return "Task completed";
}
};
// 提交任务并返回Future
Future<String> future = executor.submit(task);
// 设置任务超时时间为1秒
executor.schedule(() -> {
if (!future.isDone()) {
System.out.println("Task timed out");
future.cancel(true); // 取消任务
}
}, 1, TimeUnit.SECONDS); // 超时设置为1秒
try {
String result = future.get(); // 获取任务结果
System.out.println(result);
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
} finally {
executor.shutdown();
}
}
}