17370845950

Executors是Java中用于创建线程池的工具类，提供newFixedThreadPool、newCachedThreadPool、newSingleThreadExecutor和newScheduledThreadPool四种常用线程池，分别适用于固定并发、短期任务、串行执行和定时调度场景，但生产环境推荐手动配置ThreadPoolExecutor以避免资源耗尽风险。

在Java中，Executors 是一个工具类，提供了静态方法来创建各种类型的线程池。这些线程池基于 ExecutorService 接口，能够简化并发编程中的任务调度和线程管理。下面介绍几种常见的线程池类型及其使用方式。

1. newFixedThreadPool：固定大小的线程池

该方法创建一个线程数固定的线程池，适用于负载较重且任务数量可预测的场景。

• 核心线程数和最大线程数相同
• 多余任务会被放入无界队列等待执行
• 适合长期运行的任务

示例代码：

ExecutorService fixedPool = Executors.newFixedThreadPool(4);
fixedPool.submit(() -> {
    System.out.println("Task running on " + Thread.currentThread().getName());
});
// 使用完后应关闭
fixedPool.shutdown();

2. newCachedThreadPool：可缓存的线程池

创建一个可根据需要创建新线程的线程池，适用于大量短期异步任务。

• 线程空闲超过60秒会被回收
• 必要时会创建新线程
• 可能导致线程数过多，消耗系统资源

示例代码：

ExecutorService cachedPool = Executors.newCachedThreadPool();
cachedPool.execute(() -> {
    System.out.println("Short task executed by " + Thread.currentThread().getName());
});
cachedPool.shutdown();

3. newSingleThreadExecutor：单线程线程池

仅使用一个工作线程执行所有任务，保证任务按顺序执行。

• 只有一个线程处理所有任务
• 任务排队执行，不会并发
• 适合需要串行执行的场景

示例代码：

ExecutorService singlePool = Executors.newSingleThreadExecutor();
singlePool.submit(() -> System.out.println("Only one thread"));
singlePool.shutdown();

4. newScheduledThreadPool：支持定时及周期性任务执行

用于执行延迟或周期性任务，如定时清理、心跳检测等。

• 可以安排任务在指定延迟后执行
• 支持周期性重复执行
• 常用于定时任务调度

示例代码：

ScheduledExecutorService scheduledPool = Executors.newScheduledThreadPool(2);
scheduledPool.schedule(() -> {
    System.out.println("Delayed task executed");
}, 3, TimeUnit.SECONDS);

scheduledPool.scheduleAtFixedRate(() -> {
    System.out.println("Running every 2 seconds");
}, 0, 2, TimeUnit.SECONDS);
// 注意：周期任务需手动停止，否则持续运行

基本上就这些常见用法。虽然 Executors 提供了便捷的创建方式，但在生产环境中建议优先使用 ThreadPoolExecutor 手动配置线程池参数，避免因无界队列或无限创建线程导致资源耗尽问题。