Java中ExecutorService线程池使用

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. 创建和使用线程池

下面是一个使用固定线程池除去执行多个任务的示例：

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 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 能有效提升应用性能，关键是根据业务场景选择合适的线程池类型，并记得及时关闭资源。不复杂但容易忽略细节。