Java线程池如何高效管理任务

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<T>任务时，返回Future<T>，可用于获取计算结果

Future<String> future = executor.submit(() -> {
    return "任务完成";
});
String result = future.get(); // 获取结果，可能抛出异常
System.out.println(result);

合理关闭线程池

任务完成后必须显式关闭线程池，避免资源泄漏：

• 调用shutdown()：不再接受新任务，等待已提交任务执行完毕
• 调用shutdownNow()：尝试中断所有正在执行的任务，并停止接收新任务
• 配合awaitTermination()使用，设置最大等待时间

executor.shutdown();
try {
    if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
        executor.shutdownNow();
    }
} catch (InterruptedException e) {
    executor.shutdownNow();
    Thread.currentThread().interrupt();
}

基本上就这些。掌握线程池的创建、任务提交和安全关闭，就能在实际开发中高效管理并发任务。注意避免使用Executors默认提供的无界队列线程池，防止内存溢出，必要时可通过ThreadPoolExecutor手动配置核心参数。