17370845950

Java中ExecutorService需通过Executors工厂方法或手动构建ThreadPoolExecutor创建；常用方式包括newFixedThreadPool（固定线程数、无界队列）、newSingleThreadExecutor（单线程串行）、newCachedThreadPool（弹性线程、SynchronousQueue）和newScheduledThreadPool（定时任务）；自Java 9起推荐显式构造ThreadPoolExecutor以控制参数。

Java 中 ExecutorService 本身是接口，不能直接 new，必须通过 Executors 工具类提供的静态工厂方法创建，或者手动实现（极少用）。常用且推荐的方式是使用 Executors 提供的几种标准创建方法，对应不同业务场景。

固定线程数的线程池（newFixedThreadPool）

创建一个可重用、固定数量线程的线程池。所有任务排队等待，线程数恒定，适合负载稳定、资源可控的场景。

• 底层基于 ThreadPoolExecutor，核心线程数 = 最大线程数 = 指定值，队列默认是无界 LinkedBlockingQueue
• 注意：无界队列 + 固定线程可能导致 OOM（如任务提交速度远超执行速度）
• 示例：ExecutorService pool = Executors.newFixedThreadPool(4);

单线程线程池（newSingleThreadExecutor）

内部只维护一个工作线程，所有任务串行执行，保证顺序性和线程安全性，适合需要按提交顺序处理的任务。

• 本质是 newFixedThreadPool(1) 的封装，但返回的是 FinalizableDelegatedExecutorService，禁止调用 shutdownNow() 等破坏性操作
• 队列仍是无界，同样要注意堆积风险
• 示例：ExecutorService pool = Executors.newSingleThreadExecutor();

可缓存的线程池（newCachedThreadPool）

适用于大量短生命周期、轻量级异步任务的场景。线程数不固定，空闲 60 秒自动回收，需要时新建线程（理论上无上限）。

• 核心线程数为 0，最大线程数为 Integer.MAX_VALUE，使用 SynchronousQueue（不存储任务，直接移交）
• 高并发突发任务下可能创建过多线程，导致系统资源耗尽
• 示例：ExecutorService pool = Executors.newCachedThreadPool();

定时任务线程池（newScheduledThreadPool）

支持延迟执行和周期性执行任务，是 ScheduledExecutorService 的实现，比 Timer 更健壮（线程安全、异常不中断调度）。

• 底层也是 ThreadPoolExecutor 扩展，支持 schedule、scheduleAtFixedRate、scheduleWithFixedDelay
• 注意：它不是普通 ExecutorService 的子集，而是扩展接口，但可向上转型使用
• 示例：ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(2);

new ThreadPoolExecutor(4, 8, 60L, TimeUnit.SECONDS, new ArrayBlockingQueue(100), new CustomThreadFactory(), new ThreadPoolExecutor.CallerRunsPolicy());

基本上就这些主流创建方式。用对方法的前提是理解背后线程池的参数逻辑，而不是只记名字。