CallerRunsPolicy让提交任务的主线程同步执行被拒绝任务，实现主动减速与防压垮；需配合有界队列使用，适用于短小、无阻塞任务，避免拖垮调用链。
在 Java 线程池中，CallerRunsPolicy 是一种简单却有效的拒绝策略，它让**主线程（即提交任务的线程）自己执行被拒绝的任务**，从而起到“主动减速、自我保护”的作用，避免系统因任务积压而雪崩。这不是兜底补救，而是通过阻塞调用方来反向抑制上游流量，是典型的“防压垮”设计。
CallerRunsPolicy 的核心逻辑
当线程池已满（工作队列也满、线程数已达 maximumPoolSize），新任务无法入队也无法创建新线程时，线程池会触发拒绝策略。CallerRunsPolicy 不丢弃、不抛异常、不丢日志，而是直接在 当前调用线程（比如主线程或 Web 请求线程）中同步执行该任务。这带来两个关键效果：
- 调用线程被占用，无法立即提交下一个任务 → 降低生产速率
- 任务仍被执行（不丢失），但延迟由上游承担 → 压力前移，保护下游线程池和资源
如何正确配置并启用 CallerRunsPolicy
需在构建 ThreadPoolExecutor 时显式传入该策略。注意：不能只靠默认构造函数，必须手动指定拒绝策略。
ThreadPoolExecutor executor = new ThreadPoolExecutor(
2, // corePoolSize
4, // maximumPoolSize
60L, // keepAliveTime
TimeUnit.SECONDS,
new ArrayBlockingQueue<>(5), // 有界队列，必须！
new ThreadPoolExecutor.CallerRunsPolicy() // 关键：启用该策略
);
⚠️ 重点提醒： 若使用无界队列（如 LinkedBlockingQueue 无参构造），任务永远不会触发拒绝策略 —— 队列无限堆积，内存耗尽，反而更危险。所以 必须配用有界队列 + CallerRunsPolicy 才能生效。
Alibabacloud Sdk Client Initialization For Java
下载
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
立即学习“Java免费学习笔记（深入）”；
它如何实现“防压垮”？—— 主线程协助的真实含义
所谓“主线程协助”，不是让主线程帮忙多干活，而是让它“卡住”。例如在 Spring MVC 接口里：
- 用户请求到达 Tomcat 线程（主线程之一），调用
executor.submit(task) - 若线程池已饱和，
CallerRunsPolicy触发 → 当前 Tomcat 线程开始执行task.run() - 该 Tomcat 线程被占住，无法处理下一个 HTTP 请求 → 全局 QPS 自然下降
- 客户端感受到响应变慢或超时，自动重试退避或降级 → 流量被柔性削峰
这是一种**基于线程阻塞的负反馈调节机制**，无需额外限流组件，轻量且符合 JVM 线程模型。
使用时的关键注意事项
- 任务必须短小、无阻塞、无依赖：因为主线程执行它，若任务耗时长或加锁等待，会拖垮整个调用链（如阻塞 Web 容器线程）
- 适合 I/O 轻、CPU 时间可控的业务逻辑；不适合 DB 查询、远程调用等不确定耗时操作
- 可结合监控观察
getRejectedExecutionCount()，持续触发说明容量长期不足，需扩容或优化任务 - 与熔断降级配合更佳：当拒绝率持续偏高，可触发开关自动关闭非核心功能
