Java中通过ExecutorService接口实现线程池管理，使用Executors工具类创建固定、缓存、单线程及定时线程池，提交任务可选submit()方法执行Runnable或Callable并获取Future结果，需调用shutdown()或shutdownNow()安全关闭线程池，推荐手动配置ThreadPoolExecutor避免无界队列导致内存溢出。
Java中实现线程池管理任务的核心是使用java.util.concurrent包中的ExecutorService接口及其实现类。通过线程池可以有效控制并发线程数量，复用线程资源，提高系统性能和响应速度。
使用ExecutorService创建线程池
Java提供了Executors工具类来快速创建常见的线程池类型：
- newFixedThreadPool(int nThreads)：创建固定大小的线程池
- newCachedThreadPool()：创建可缓存的线程池，线程数根据需要动态扩展
- newSingleThreadExecutor()：创建单个线程的线程池
- newScheduledThreadPool(int corePoolSize)：支持定时或周期性任务执行
ExecutorService executor = Executors.newFixedThreadPool(4);
executor.submit(() -> {
System.out.println("任务正在执行，线程名：" + Thread.currentThread().getName());
});
提交任务并处理结果
可以通过submit()方法提交Runnable或Callable任务，后者可返回结果：
- 提交
Runnable任务时，返回Future>，调用get()将阻塞直到任务完成 - 提交
Callable任务时，返回Future，可用于获取计算结果
Futurefuture = executor.submit(() -> { return "任务完成"; }); String result = future.get(); // 获取结果，可能抛出异常 System.out.println(result);
合理关闭线程池
任务完成后必须显式关闭线程池，避免资源泄漏：
立即学习“Java免费学习笔记（深入）”；
- 调用
shutdown()：不再接受新任务，等待已提交任务执行完毕 - 调用
shutdownNow()：尝试中断所有正在执行的任务，并停止接收新任务 - 配合
awaitTermination()使用，设置最大等待时间
executor.shutdown();
try {
if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
executor.shutdownNow();
}
} catch (InterruptedException e) {
executor.shutdownNow();
Thread.currentThread().interrupt();
}
基本上就这些。掌握线程池的创建、任务提交和安全关闭，就能在实际开发中高效管理并发任务。注意避免使用Executors默认提供的无界队列线程池，防止内存溢出，必要时可通过ThreadPoolExecutor手动配置核心参数。
