线程池任务拒绝时须同步记录日志并执行业务降级；日志必须包含拒绝时间（毫秒）、线程池名称、运行状态快照、拒绝策略类型及任务信息；降级按任务重要性分级：非核心任务丢弃，可延迟任务入延迟队列，主流程任务转同步调用（带超时熔断），强一致任务入库告警；配合[rejected_task]日志标记、prometheus拒绝计数器及阈值告警实现可观测性。
线程池任务被拒绝时，需同时做好日志记录与业务降级，不能只打印堆栈或直接抛异常。核心是：明确拒绝原因、保留关键上下文、触发可预期的备用逻辑。
拒绝时必须记录的关键日志信息
日志不是为了“有”，而是为了后续排查和监控。以下字段缺一不可：
- 拒绝时间：精确到毫秒，便于关联监控指标突增点
-
线程池名称：通过
ThreadPoolExecutor的自定义构造或包装类统一标识（如"order-submit-pool"） -
当前运行状态：用
getActiveCount()、getQueue().size()、getPoolSize()、getLargestPoolSize()输出快照 -
拒绝策略类型：区分是
AbortPolicy、CallerRunsPolicy还是自定义策略 -
被拒任务信息：至少记录
task.getClass().getSimpleName()和toString()（若重写了），敏感字段脱敏
用自定义 RejectedExecutionHandler 实现统一处理
不要依赖默认策略。继承并实现 RejectedExecutionHandler，把日志 + 降级封装在一起：
Alibabacloud Sdk Client Initialization For Java
下载
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
public class LoggingAndFallbackPolicy implements RejectedExecutionHandler {
private final Logger logger = LoggerFactory.getLogger(LoggingAndFallbackPolicy.class);
private final FallbackService fallbackService;
public LoggingAndFallbackPolicy(FallbackService fallbackService) {
this.fallbackService = fallbackService;
}
@Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
String poolName = getPoolName(executor);
String taskName = r.getClass().getSimpleName();
int queueSize = executor.getQueue().size();
int active = executor.getActiveCount();
int poolSize = executor.getPoolSize();
logger.warn("Task rejected in pool [{}]: task=[{}], " +
"active={} poolSize={} queueSize={} max={} core={}",
poolName, taskName, active, poolSize, queueSize,
executor.getMaximumPoolSize(), executor.getCorePoolSize());
// 记录 MDC 上下文（如有 traceId）
if (MDC.get("traceId") != null) {
logger.warn("TraceId context: {}", MDC.get("traceId"));
}
// 执行降级逻辑（同步或异步，视业务容忍度而定）
fallbackService.handleRejected(r);
}
}
降级策略要分场景设计，不能一刀切
降级不是“随便找个方法执行”，而是按任务重要性分级响应：
- 非核心异步任务（如埋点上报、日志聚合）：直接丢弃，记录 warn 日志即可，不触发任何补偿
- 可延迟执行的任务（如通知推送、缓存预热）：写入本地队列或 Redis 延迟队列，由后台定时重试
-
影响主流程的任务（如订单创建后的库存扣减）：转为同步调用（类似
CallerRunsPolicy），但需加超时控制和熔断，避免阻塞主线程 - 强一致要求任务（如支付结果确认）：记录到 DB 拒绝表，触发人工介入或告警，不自动降级
配合监控与告警，让拒绝可感知
光记日志不够，要让团队第一时间知道：
- 在日志中固定打标，例如
[REJECTED_TASK]前缀，方便 ELK 或 Grafana 日志系统聚合统计 - 用 Micrometer 或 Prometheus 暴露拒绝计数器：
threadpool.rejections{pool="xxx"}，配置 1 分钟内 >5 次即告警 - 拒绝率超过 1% 时，自动触发线程池参数检查脚本（如对比当前 QPS 与线程池吞吐能力）
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
