ExecutorService是Java中用于管理线程池的接口，通过复用线程提升性能。1. 它位于java.util.concurrent包，支持任务提交、生命周期管理，常见实现有newFixedThreadPool、newCachedThreadPool等。2. 使用示例如创建4线程池执行8个任务，由线程自动调度。3. submit()可返回Future获取结果，execute()仅执行无返回。4. 必须调用shutdown()或shutdownNow()关闭线程池，推荐结合awaitTermination确保优雅关闭。合理选择类型并及时释放资源是关键。
在Java中，ExecutorService 是并发编程的重要工具，它提供了一种高效管理线程的方式，避免频繁创建和销毁线程带来的性能开销。通过线程池复用线程，可以提升系统响应速度并控制资源使用。
1. 什么是ExecutorService
ExecutorService 是 java.util.concurrent 包中的接口，用于异步执行任务。它扩展了 Executor 接口，支持管理线程生命周期、提交任务并获取结果。
常见实现由 Executors 工厂类提供，例如：
- newFixedThreadPool(n)：创建固定数量线程的线程池
- newCachedThreadPool()：创建可缓存线程池，按需创建线程
- newSingleThreadExecutor()：单线程池，保证任务顺序执行
- newScheduledThreadPool(n)：支持定时或周期性任务执行
2. 创建和使用线程池
下面是一个使用固定线程池除去执行多个任务的示例：
立即学习“Java免费学习笔记（深入）”；
ExecutorService executor = Executors.newFixedThreadPool(4);
for (int i = 0; i < 8; i++) {
final int taskId = i;
executor.submit(() -> {
System.out.println("任务 " + taskId + " 正在由线程 " + Thread.currentThread().getName() + " 执行");
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
System.out.println("任务 " + taskId + " 完成");
});
}
任务被提交后由线程池内部线程自动调度执行，无需手动启动线程。
3. 提交任务的两种方式
submit() 和 execute() 都可用于提交任务，但有区别：
- execute(Runnable)：无返回值，适用于不需要结果的任务
- submit() 可接受 Runnable 或 Callable，返回 Future 对象，可用于获取执行结果或判断是否完成
例如获取任务结果：
Future<String> future = executor.submit(() -> {
return "处理完成";
});
String result = future.get(); // 阻塞等待结果
System.out.println(result);
4. 关闭线程池
任务执行完毕后必须关闭线程池，防止资源泄漏：
- shutdown()：不再接收新任务，等待已提交任务执行完毕
- shutdownNow()：尝试中断所有正在执行的任务，并返回未执行的任务列表
推荐使用 shutdown() 并配合 awaitTermination 等待优雅关闭：
executor.shutdown();
try {
if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
executor.shutdownNow();
}
} catch (InterruptedException e) {
executor.shutdownNow();
Thread.currentThread().interrupt();
}
基本上就这些。合理使用 ExecutorService 能有效提升应用性能，关键是根据业务场景选择合适的线程池类型，并记得及时关闭资源。不复杂但容易忽略细节。
