Java 线程池详解

从原理到实战，全面掌握线程池核心技能

一、线程池核心原理

提交任务

线程池

任务队列
workQueue

核心线程1

核心线程2

核心线程N

临时线程1

临时线程2

任务

线程池 = 任务队列 + 工作线程

二、线程池处理流程

是

否

否

是

是

否

提交任务

线程数 < corePoolSize?

创建新线程

队列已满?

执行任务

加入队列等待

线程数 < maximumPoolSize?

创建临时线程

触发拒绝策略

拒绝任务

执行流程：

1. 线程数 < corePoolSize → 创建新线程执行
2. 线程数 >= corePoolSize → 任务加入队列
3. 队列满 + 线程数 < maximumPoolSize → 创建临时线程
4. 队列满 + 线程数 = maximumPoolSize → 拒绝任务

三、线程池 7 大参数

newThreadPoolExecutor(int corePoolSize,// 1. 核心线程数int maximumPoolSize,// 2. 最大线程数long keepAliveTime,// 3. 空闲线程存活时间TimeUnit unit,// 4. 时间单位BlockingQueue<Runnable> workQueue,// 5. 任务队列ThreadFactory threadFactory,// 6. 线程工厂RejectedExecutionHandler handler // 7. 拒绝策略);

四、任务队列选择

// 有界队列（推荐）newArrayBlockingQueue<>(100)// 无界队列（谨慎使用）newLinkedBlockingQueue<>()// 同步队列（适合耗时短的任务）newSynchronousQueue<>()

五、拒绝策略

// 默认：抛异常newAbortPolicy()// 调用者执行newCallerRunsPolicy()// 丢弃任务newDiscardPolicy()// 丢弃最老任务newDiscardOldestPolicy()

六、线程工厂

ThreadFactory factory =newThreadFactory(){privateAtomicInteger count =newAtomicInteger(1);@OverridepublicThreadnewThread(Runnable r){Thread thread =newThread(r); thread.setName("MyThread-"+ count.getAndIncrement()); thread.setDaemon(false);// 非守护线程return thread;}};

常用配置：

• 线程命名
• 守护线程设置
• 线程优先级

七、Executors 工具类

阿里巴巴规范：不推荐使用！

// 不推荐：可能 OOMExecutorService pool =Executors.newFixedThreadPool(10);// 推荐：手动配置ExecutorService pool =newThreadPoolExecutor(10,50,60L,TimeUnit.SECONDS,newArrayBlockingQueue<>(100),newThreadPoolExecutor.AbortPolicy());

八、线程池状态

创建

shutdown()

shutdownNow()

队列空 + 无活跃线程

无活跃线程

terminated()执行完毕

RUNNING

SHUTDOWN

STOP

TIDYING

TERMINATED

九、实战配置

1. CPU 密集型任务

// CPU 核心数 + 1int cpuCores =Runtime.getRuntime().availableProcessors();newThreadPoolExecutor( cpuCores +1, cpuCores +1,0L,TimeUnit.MILLISECONDS,newLinkedBlockingQueue<>(1000));

2. IO 密集型任务

// CPU 核心数 * 2int cpuCores =Runtime.getRuntime().availableProcessors();newThreadPoolExecutor( cpuCores *2, cpuCores *2,60L,TimeUnit.SECONDS,newLinkedBlockingQueue<>(1000));

3. 混合型任务

newThreadPoolExecutor( cpuCores +1, cpuCores *2,60L,TimeUnit.SECONDS,newArrayBlockingQueue<>(500));

十、线程池监控

1. 常用监控方法

ThreadPoolExecutor executor =newThreadPoolExecutor(...);// 活跃线程数 executor.getActiveCount();// 队列任务数 executor.getQueue().size();// 已完成任务数 executor.getCompletedTaskCount();// 总任务数 executor.getTaskCount();// 线程池是否Terminated executor.isTerminated();

2. 线程池监控示例

publicclassThreadPoolMonitor{publicstaticvoidprintStatus(ThreadPoolExecutor executor){System.out.println("====================");System.out.println("线程池大小: "+ executor.getPoolSize());System.out.println("活跃线程数: "+ executor.getActiveCount());System.out.println("队列任务数: "+ executor.getQueue().size());System.out.println("已完成任务: "+ executor.getCompletedTaskCount());System.out.println("总任务数: "+ executor.getTaskCount());System.out.println("====================");}}

十一、优雅关闭线程池

ThreadPoolExecutor executor =newThreadPoolExecutor(...);// 1. 拒绝新任务 executor.shutdown();// 2. 等待任务完成（带超时）if(!executor.awaitTermination(60,TimeUnit.SECONDS)){// 3. 强制中断 executor.shutdownNow();}// 或者直接暴力关闭 executor.shutdownNow();

关闭原则：

1. 先 shutdown() 拒绝新任务
2. 等待任务完成或超时
3. 超时后 shutdownNow() 强制中断

十二、常见问题

1. 线程池参数设置多大？

2. 队列容量设置多大？

// 经验公式 队列容量 = 核心线程数 * 期望响应时间(秒)*2

3. 线程池会 OOM 吗？

会！常见原因：

• LinkedBlockingQueue 无界队列堆积
• 任务过多且执行慢
• 拒绝策略不合理

解决：

• 使用有界队列
• 合理设置 maximumPoolSize
• 监控队列大小

4. 核心线程会被回收吗？

默认不会！设置允许回收：

executor.allowCoreThreadTimeOut(true);

十三、总结

线程池核心

参数配置
core/max/queue

队列选择
Array/Linked/Synchronous

拒绝策略
4种策略

监控与调优

合理配置
避免 OOM

优雅关闭
防止任务丢失

核心要点：