Java自定义RejectedExecutionHandler需实现接口并传入线程池，核心是按业务场景选择拒绝逻辑；JDK提供AbortPolicy、CallerRunsPolicy、DiscardPolicy、DiscardOldestPolicy四种内置策略，分别适用于快速失败、降级减压、吞吐优先和保留最新任务等场景；自定义实现应轻量、非阻塞，避免死循环，推荐手动构建线程池时传入，并结合监控告警。
Java 中自定义 RejectedExecutionHandler 的核心是实现接口并传入线程池，关键在于根据业务场景选择合适的拒绝逻辑，而不是简单抛异常或丢任务。
理解四种内置拒绝策略的适用场景
JDK 提供了四个标准实现，先明确它们的行为再决定是否需要自定义：
-
AbortPolicy（默认）：直接抛
RejectedExecutionException，适合无法容忍任务丢失、需快速失败的场景 - CallerRunsPolicy：由提交任务的线程（非线程池线程）同步执行该任务，可减缓提交速度，适合轻量级降级
- DiscardPolicy：静默丢弃，不报错，适合任务可丢失、吞吐优先的后台采集类业务
- DiscardOldestPolicy：丢弃队列头部任务，再尝试提交当前任务，适合希望尽量保留最新任务的场景（如实时通知）
自定义 RejectedExecutionHandler 的典型写法
实现接口只需重写 rejectedExecution(Runnable r, ThreadPoolExecutor executor) 方法。常见定制方向包括日志记录、监控上报、异步兜底、降级处理等：
public class LoggingRejectHandler implements RejectedExecutionHandler {
private static final Logger log = LoggerFactory.getLogger(LoggingRejectHandler.class);
@Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
// 记录被拒任务信息（注意避免在高并发下打满日志）
if (log.isWarnEnabled()) {
log.warn("Task {} rejected from {} with queue size {}, pool size {}/{}",
r.getClass().getSimpleName(),
executor,
executor.getQueue().size(),
executor.getPoolSize(),
executor.getMaximumPoolSize());
}
// 可选：将任务转存到本地延迟队列、Kafka 或 DB，后续重试
// saveToRetryQueue(r);
// 可选：触发告警（如调用 Prometheus Counter 或发送钉钉消息）
// alertOnRejection();
}
}
</font>
<H3>配置方式：构造线程池时传入</H3>
<p>所有基于 <code>ThreadPoolExecutor</code> 构建的线程池都支持传入自定义 handler，包括 <code>Executors</code> 工具类创建的（需强转）和手动构建的：</p><p><span>立即学习</span>“<a href="https://pan.quark.cn/s/c1c2c2ed740f" style="text-decoration: underline !important; color: blue; font-weight: bolder;" rel="nofollow" target="_blank">Java免费学习笔记（深入）</a>”；</p>
<ul>
<li><strong>手动构建（推荐）</strong>：
<font color="gray">
<pre class="brush:php;toolbar:false;">
ThreadPoolExecutor executor = new ThreadPoolExecutor(
2, 4, 30L, TimeUnit.SECONDS,
new LinkedBlockingQueue<>(100),
new ThreadFactoryBuilder().setNameFormat("biz-task-%d").build(),
new LoggingRejectHandler() // ← 自定义 handler 在这里传入
);
Executors.newFixedThreadPool(n) 返回的是 ThreadPoolExecutor 子类，可强转后调用 setRejectedExecutionHandler()：
ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newFixedThreadPool(4); executor.setRejectedExecutionHandler(new LoggingRejectHandler());
注意事项与最佳实践
自定义 handler 虽灵活，但容易踩坑：
- 拒绝逻辑必须轻量，不能阻塞、不能耗时（比如同步写 DB 或远程调用），否则会拖垮提交线程
- 避免在 handler 中再次提交任务到同一线程池，极易引发死循环或堆栈溢出
- 如果要做异步兜底（如落库重试），建议使用独立线程池或消息队列，与主业务解耦
- 生产环境建议结合监控（如统计拒绝次数）+ 告警，及时发现线程池配置不合理或流量突增
