java线程池拒绝任务时，应实现rejectedexecutionhandler接口自定义处理器，在rejectedexecution方法中记录含线程池名、任务类、队列大小等上下文的结构化日志，避免耗时操作，配合mdc透传traceid，并通过构造参数注入threadpoolexecutor。
Java 线程池在任务被拒绝时，可以通过实现 RejectedExecutionHandler 接口来自定义拒绝策略，并在其中加入日志记录逻辑。关键不是“替换默认策略”，而是“接管拒绝流程并主动记日志”。
实现自定义拒绝处理器并记录日志
最直接的方式是新建一个类，实现 RejectedExecutionHandler，在 rejectedExecution 方法中打印日志（推荐用 SLF4J 或 Log4j），再根据需要决定是否抛异常或丢弃任务。
- 日志内容建议包含：线程池名称、任务类名、队列大小、活跃线程数、最大线程数等上下文信息，便于排查压测或突发流量问题
- 避免在拒绝处理中执行耗时操作（如写文件、远程调用），否则可能阻塞线程池的拒绝判断路径
- 可配合 MDC 在日志中透传 traceId（如果任务本身携带），提升链路追踪能力
把自定义策略应用到线程池
创建 ThreadPoolExecutor 时，将自定义处理器作为构造参数传入；若使用 Executors 工具类（不推荐生产环境直接用），需手动包装为 ThreadPoolExecutor 后设置。
- 示例：
new ThreadPoolExecutor(core, max, keepAlive, unit, queue, threadFactory, new LoggingRejectPolicy()) - Spring 环境下可通过
@Bean定义线程池，并注入自定义RejectedExecutionHandler实例 - 注意：
Executors.newFixedThreadPool()等方法内部使用的是AbortPolicy，不会记录日志，必须显式替换
常用拒绝策略对比与日志增强建议
四种内置策略行为不同，日志侧重点也应有差异：
-
AbortPolicy（默认）：抛
RejectedExecutionException，适合记 ERROR 日志 + 异常堆栈 - CallerRunsPolicy：由提交线程自己执行任务，适合记 WARN 日志 + 提交线程名，提示系统已过载
- DiscardPolicy：静默丢弃，建议至少记 INFO 日志说明“任务已被丢弃”，否则问题难发现
- DiscardOldestPolicy：丢弃队首任务再重试提交，适合记 DEBUG 日志 + 队首任务类型，观察是否高频丢弃老任务
进阶：结合监控上报拒绝事件
单纯打日志不够，可进一步将拒绝次数、原因、时间戳等指标同步到 Prometheus、Micrometer 或业务监控平台。
- 在拒绝处理器中调用
MeterRegistry.counter("threadpool.rejected", "policy", "abort").increment() - 对高频拒绝场景，可加限流（如每分钟最多记录 10 条 warn 日志），防止日志刷屏
- 线上建议开启异步日志（如 Logback 的 AsyncAppender），避免日志 IO 拖慢拒绝响应
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
