前言线程池是Java并发编程中最常用的工具之一但很多开发者只停留在“会用”层面。面试中面试官往往通过线程池考察你对并发编程的理解深度——参数如何设置为什么这样设置拒绝策略如何选择本文将深入剖析线程池的七大核心参数、参数设置的核心逻辑以及四种拒绝策略的适用场景。一、线程池的七大核心参数ThreadPoolExecutor是Java线程池的核心实现类其构造函数包含7个关键参数publicThreadPoolExecutor(intcorePoolSize,// 核心线程数intmaximumPoolSize,// 最大线程数longkeepAliveTime,// 空闲存活时间TimeUnitunit,// 时间单位BlockingQueueRunnableworkQueue,// 阻塞队列ThreadFactorythreadFactory,// 线程工厂RejectedExecutionHandlerhandler// 拒绝策略)1.1 corePoolSize核心线程数定义线程池中始终保持存活的线程数即使这些线程处于空闲状态也不会被销毁除非设置了allowCoreThreadTimeOut(true)。执行逻辑当提交任务时如果当前线程数 corePoolSize会立即创建新线程执行任务即使有其他空闲线程也会优先创建新线程直到达到核心线程数1.2 maximumPoolSize最大线程数定义线程池允许创建的最大线程数量包括核心线程和非核心线程。执行逻辑当任务队列已满且当前线程数 maximumPoolSize 时会创建新的非核心线程来执行任务1.3 keepAliveTime unit空闲存活时间定义非核心线程空闲时的存活时间。超过这个时间空闲的非核心线程会被回收。特殊点如果设置了allowCoreThreadTimeOut(true)核心线程也会受此参数影响。1.4 workQueue阻塞队列定义用于存放等待执行的任务的阻塞队列。常用队列类型队列特点适用场景LinkedBlockingQueue无界队列默认Integer.MAX_VALUE任务量可控防止OOM需注意ArrayBlockingQueue有界队列需指定容量任务量稳定需要精确控制SynchronousQueue不存储任务直接移交需要直接执行的任务配合无限线程数PriorityBlockingQueue支持优先级排序任务有优先级需求1.5 threadFactory线程工厂定义用于创建新线程的工厂默认实现为Executors.defaultThreadFactory()。最佳实践自定义ThreadFactory设置有意义的线程名称便于问题排查ThreadFactorynamedThreadFactorynewThreadFactoryBuilder().setNameFormat(my-pool-%d).setDaemon(true).build();1.6 handler拒绝策略当线程池已关闭、或线程数已达maximumPoolSize且队列已满时新提交的任务会被拒绝。JDK提供了四种内置策略下文详细解析。二、线程池的工作流程理解参数后我们来看线程池处理任务的核心流程提交任务 ↓ 当前线程数 corePoolSize ├── 是 → 创建核心线程执行任务 └── 否 → 尝试放入队列 ↓ 队列是否已满 ├── 否 → 成功入队等待执行 └── 是 → 当前线程数 maximumPoolSize ├── 是 → 创建非核心线程执行任务 └── 否 → 触发拒绝策略关键点队列已满后才创建非核心线程而不是核心线程满了就立即创建。三、核心参数如何设置这是面试中考察深度的关键点。线程池大小的设置需要根据任务类型来判断。3.1 任务类型分类① CPU密集型特点任务主要消耗CPU资源如复杂计算、加解密、正则匹配等。公式线程数 CPU核心数 1原理CPU密集型任务的瓶颈在CPU线程过多会导致频繁的上下文切换反而降低吞吐量。多出的1个线程用于应对页缺失等突发情况。② I/O密集型特点任务大量时间在等待I/O操作如数据库查询、HTTP调用、文件读写等。公式线程数 CPU核心数 × (1 平均等待时间 / 平均工作时间)简化版线程数 CPU核心数 × 2原理I/O密集型任务在等待期间不占用CPU可以让更多线程并发执行提高CPU利用率。③ 混合型如果任务同时包含CPU计算和I/O操作可以将任务拆分为两个线程池分别处理。3.2 队列大小的设置有界队列推荐使用设置合理的容量防止突发流量导致OOM队列大小参考QPS × 平均响应时间 × 容忍的等待时长3.3 压测调优实际工作中理论公式只是起点最终需要通过压测验证。逐步调整参数观察TPS、响应时间、CPU使用率等指标找到最优配置。四、四种拒绝策略详解当线程池无法处理新任务时拒绝策略RejectedExecutionHandler决定如何处理。4.1 AbortPolicy默认策略行为直接抛出RejectedExecutionException异常。publicstaticclassAbortPolicyimplementsRejectedExecutionHandler{publicvoidrejectedExecution(Runnabler,ThreadPoolExecutore){thrownewRejectedExecutionException(Task r.toString() rejected from e.toString());}}适用场景关键业务任务不允许丢失失败需要立即感知和处理。4.2 CallerRunsPolicy行为由提交任务的线程调用者自己执行该任务。publicstaticclassCallerRunsPolicyimplementsRejectedExecutionHandler{publicvoidrejectedExecution(Runnabler,ThreadPoolExecutore){if(!e.isShutdown()){r.run();// 调用线程直接执行}}}效果调用线程执行任务期间无法继续提交新任务天然实现了限流降级。适用场景对任务执行实时性要求不高允许一定程度的延迟且不希望丢失任务。4.3 DiscardPolicy行为静默丢弃当前任务不抛出任何异常。publicstaticclassDiscardPolicyimplementsRejectedExecutionHandler{publicvoidrejectedExecution(Runnabler,ThreadPoolExecutore){// 什么都不做直接丢弃}}适用场景非关键任务如日志上报、监控数据采集丢失可接受。4.4 DiscardOldestPolicy行为丢弃队列头部等待时间最久的任务然后重新尝试提交当前任务。publicstaticclassDiscardOldestPolicyimplementsRejectedExecutionHandler{publicvoidrejectedExecution(Runnabler,ThreadPoolExecutore){if(!e.isShutdown()){e.getQueue().poll();// 丢弃队列头部e.execute(r);// 重新尝试提交}}}适用场景追求最新数据的场景如实时推荐、最新消息推送可以丢弃旧数据。4.5 自定义拒绝策略实现RejectedExecutionHandler接口可以自定义拒绝逻辑如记录日志、写入消息队列、发送告警等publicclassCustomRejectedPolicyimplementsRejectedExecutionHandler{OverridepublicvoidrejectedExecution(Runnabler,ThreadPoolExecutorexecutor){// 记录日志log.warn(Task rejected: {},r.toString());// 发送告警alertService.send(线程池任务拒绝);// 降级处理存入数据库或MQsaveToDatabase(r);}}五、常见问题与陷阱5.1 Executors 工具类的隐患Executors提供的快捷方法存在一定风险方法问题newFixedThreadPool使用无界队列LinkedBlockingQueue任务堆积可能OOMnewCachedThreadPool最大线程数为Integer.MAX_VALUE可能创建过多线程导致OOMnewSingleThreadExecutor同样使用无界队列单线程处理慢时任务堆积建议手动创建 ThreadPoolExecutor明确指定所有参数。5.2 核心线程数的动态调整ThreadPoolExecutor提供了动态调整方法// 动态调整核心线程数executor.setCorePoolSize(10);// 允许核心线程超时回收executor.allowCoreThreadTimeOut(true);5.3 线程池的监控生产环境建议暴露线程池监控指标当前线程数活跃线程数队列大小已完成任务数拒绝任务数六、总结参数作用设置建议corePoolSize核心线程数CPU密集型核心数1I/O密集型核心数×2maximumPoolSize最大线程数结合队列大小和业务峰值压测确定keepAliveTime空闲存活时间通常30s~60sworkQueue阻塞队列优先使用有界队列handler拒绝策略根据业务重要性选择线程池配置没有万能公式理解参数含义后结合业务特性、通过压测验证才能找到最适合的配置。下一篇预告Synchronized 与 ReentrantLock 的区别——从底层原理到面试话术。