Java线程池核心机制与实战配置
1. 线程执行基础
1.1 Runnable与Thread的本质关系
Runnable是任务抽象，Thread是执行载体。实现Runnable仅定义了任务逻辑，必须借助Thread才能启动：
// Runnable接口定义
public interface Runnable {
public abstract void run();
}常见误区：直接new Thread()创建线程效率低下，且缺乏生命周期管控。
1.2 同步机制synchronized
多线程环境下共享资源的访问冲突需通过锁机制解决。synchronized确保同一时刻只有一个线程进入临界区，避免数据竞争与脏读。
2. 线程池的设计价值
2.1 裸线程的缺陷
- 频繁创建销毁线程带来GC压力与上下文切换开销
- 线程数量失控导致系统资源耗尽
- 缺乏任务调度、超时控制、优雅关闭等高级能力
2.2 池化技术的优势
- 资源复用：降低线程创建成本，提升响应速度
- 流量管控：通过容量限制防止系统过载
- 功能扩展：支持延迟执行、周期任务、批量提交等场景
3. 线程池架构与运行原理
3.1 核心组件关系
Executor ← ExecutorService ← AbstractExecutorService ← ThreadPoolExecutor，形成完整的任务执行框架。
3.2 任务处理流程
- 提交任务后，若运行线程数 < corePoolSize，立即创建新线程
- 若运行线程数 ≥ corePoolSize，任务进入BlockingQueue排队
- 若队列已满且运行线程数 < maximumPoolSize，扩容创建非核心线程
- 若运行线程数 ≥ maximumPoolSize，触发拒绝策略
3.3 线程状态转换
RUNNING → SHUTDOWN → STOP → TIDYING → TERMINATED，通过ctl原子变量维护状态与线程数。
4. ExecutorService接口能力
// 优雅关闭：等待已提交任务完成，拒绝新任务
void shutdown();
// 强制关闭：尝试中断运行中线程，返回未执行的任务
List<Runnable> shutdownNow();
// 提交无返回值任务
Future<?> submit(Runnable task);
// 提交Callable获取异步结果
<T> Future<T> submit(Callable<T> task);
// 批量执行并等待全部完成
<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
throws InterruptedException;5. 工厂方法的风险（不推荐生产使用）
| 方法 | 特性 | 隐患 |
|---|---|---|
| newCachedThreadPool | core=0, max=Integer.MAX_VALUE, 60秒回收 | 允许无限创建线程，OOM风险 |
| newFixedThreadPool | core=max=n, 无界队列 | 队列无限堆积，内存溢出 |
| newSingleThreadExecutor | 单线程串行执行 | 同样使用无界队列 |
| newScheduledThreadPool | 支持定时周期任务 | max无限制，DelayedWorkQueue |
6. ThreadPoolExecutor手动构建（推荐方式）
public ThreadPoolExecutor(
int corePoolSize, // 核心线程数：长期保持的线程数量
int maximumPoolSize, // 最大线程数：扩容上限
long keepAliveTime, // 空闲线程存活时间
TimeUnit unit, // 时间单位
BlockingQueue<Runnable> workQueue, // 任务等待队列
ThreadFactory threadFactory, // 线程创建工厂（可定制命名、守护状态）
RejectedExecutionHandler handler // 饱和拒绝策略
) {
// 参数校验...
}6.1 七大参数详解
corePoolSize：线程池维持的最小线程数，即使空闲也保留（除非设置allowCoreThreadTimeOut）。
maximumPoolSize：并发上限，当队列满且核心线程全忙时，允许创建到该数量的线程。
keepAliveTime + unit：非核心线程的空闲存活时长，超时后回收至corePoolSize水平。
workQueue：任务缓冲策略的关键选择：
- ArrayBlockingQueue：有界队列，需预估容量
- LinkedBlockingQueue：无界队列，注意内存
- SynchronousQueue：直接移交，maxPoolSize需设大
- PriorityBlockingQueue：带优先级的无界队列
threadFactory：推荐自定义实现，设置有意义的线程名称、统一异常处理器。
handler：四种标准拒绝策略：
- AbortPolicy：默认，直接抛RejectedExecutionException
- CallerRunsPolicy：由提交任务的线程自己执行，提供降级缓冲
- DiscardPolicy：静默丢弃，高风险
- DiscardOldestPolicy：丢弃队列最老任务，尝试提交新任务
6.2 配置示例
ThreadPoolExecutor executor = new ThreadPoolExecutor(
4, // 核心线程：CPU密集型建议N+1
8, // 最大线程：IO密集型可设2N
60L, TimeUnit.SECONDS,
new ArrayBlockingQueue<>(100), // 有界队列防堆积
new ThreadFactoryBuilder()
.setNameFormat("order-pool-%d")
.setUncaughtExceptionHandler((t, e) -> log.error("线程异常", e))
.build(),
new ThreadPoolExecutor.CallerRunsPolicy() // 饱和时主线程执行
);