可通过自定义RejectedExecutionHandler实现带指数退避和次数限制的延迟重试，避免死循环与线程阻塞；推荐用queue.offer(r, delay, unit)异步重入，进阶方案可将任务落库或入内存队列由后台线程重试。
可以通过自定义 RejectedExecutionHandler，在任务被拒绝时主动触发重试，而不是简单丢弃或阻塞。关键在于：不中断主线程、不导致队列无限膨胀、重试有节制（带延迟和次数限制），且避免死锁或线程饥饿。
重试逻辑必须绕过默认拒绝路径
线程池触发拒绝策略的典型条件是：活跃线程已达 maximumPoolSize 且工作队列已满（尤其使用有界队列如 ArrayBlockingQueue）。此时直接调用 executor.execute(r) 会再次触发拒绝，形成死循环。所以重试不能原样“再提交一次”，而应：
- 改用异步方式重试，比如交给一个专用的轻量重试调度器（如
ScheduledThreadPoolExecutor） - 或在拒绝钩子中执行带退避的延迟重入，例如用
executor.getQueue().offer(r, delay, TimeUnit.SECONDS)（需队列为BlockingQueue且支持超时 offer） - 避免在
rejectedExecution中同步调用execute()或submit()
推荐实现：带退避的延迟重入队列
适用于大多数业务场景，不新增线程池，复用原有资源，且可控性强。示例策略如下：
public class DelayedRetryRejectHandler implements RejectedExecutionHandler {
private final long baseDelayMs = 100; // 初始延迟
private final int maxRetry = 3;
<pre class='brush:java;toolbar:false;'>@Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
if (executor.isShutdown()) return;
BlockingQueue<Runnable> queue = executor.getQueue();
if (!(queue instanceof LinkedBlockingQueue || queue instanceof ArrayBlockingQueue)) {
// 不支持 offer(timeout)，降级为日志+丢弃
log.warn("Unsupported queue type, task dropped: {}", r);
return;
}
for (int i = 0; i <= maxRetry; i++) {
try {
long delay = Math.min(baseDelayMs * (long) Math.pow(2, i), 5_000); // 指数退避，上限5s
if (queue.offer(r, delay, TimeUnit.MILLISECONDS)) {
log.debug("Task re-queued after {}ms retry #{}", delay, i);
return;
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
return;
}
}
log.warn("Task failed all retries and dropped: {}", r);
}}
- 利用队列的
offer(r, timeout, unit)尝试插入，若失败则等待后重试 - 采用指数退避（100ms → 200ms → 400ms…），防止单点雪崩
- 最大重试 3 次，总耗时可控，避免长期占用拒绝钩子线程
进阶方案：分离重试调度与执行
当业务对可靠性要求高（如支付、账单类任务），建议将重试逻辑解耦：
- 拒绝时把任务序列化（如 JSON）写入本地文件、Redis 或 Kafka，由独立消费者拉取重试
- 或放入内存重试队列（如
ConcurrentLinkedQueue），由后台定时线程扫描并择机重新提交到主池 - 配合重试次数计数、下次执行时间戳、失败原因标记，便于排查和限流
这种设计能彻底规避主线程阻塞风险，也方便做灰度重试、失败告警、人工干预等运维能力。
务必避开的陷阱
几个高频误操作会导致系统更不稳定：
- 在
rejectedExecution中直接调用executor.execute(r)—— 必然再次拒绝，栈溢出或死循环 - 用
queue.put(r)（无界阻塞）—— 主线程卡死，上游请求全部堆积 - 未判断
executor.isShutdown()—— 关闭中仍尝试重试，抛RejectedExecutionException - 重试不加延迟也不限次数 —— 短时间内大量重试加剧负载，可能引发级联故障
拒绝钩子本质是兜底通道，不是常规执行路径。设计目标是“尽力而为，及时止损”，而非强保成功。
