实战：怎么用一段极简代码证明自定义拒绝策略中直接调用 queue.put() 会把主线程变成阻塞态-java教程-PHP中文网

阻塞是因为在拒绝策略中调用queue.put()时，队列已满（如arrayblockingqueue(1)在2个任务提交后已达容量上限），而put()是阻塞方法，会无限等待空位，导致调用线程（主线程）进入waiting状态。

直接用一段可运行的代码就能验证：在自定义拒绝策略中调用 queue.put()，会让提交任务的主线程卡住（即进入阻塞态），而不是继续执行后续逻辑。

为什么会出现阻塞？

因为线程池的拒绝策略是在 addWorker() 失败后、且队列已满时触发的。此时若你在拒绝策略里调用 queue.put()，而队列容量已满（比如 ArrayBlockingQueue 且 remainingCapacity() == 0），那么 put() 就会一直等待有空位——也就是无限期阻塞当前线程（即调用 execute() 的主线程）。

极简复现代码

以下代码仅需 20 行左右，即可清晰看到主线程被卡住：

JavaStoryDevelop

你接手一个需求时，是不是经常这样："改一个小字段 → 结果把不相关的代码也改了"、"需求说得很模糊 → 做着做着发现跑偏了"、"数据库加个字段 → 上线才发现漏了数据兼容"、"做了个新功能 → 一个月后自己都忘了当时怎么设计的"、"写到一半被中断 → 再回来不知道从哪继续"；这个 Skill 就是专门解决这些问题的。它会自动探测你的项目环境（JDK、Spring Boot、ORM、数据库、前端框架），记在

下载

import java.util.concurrent.*;

public class RejectBlockDemo {
    public static void main(String[] args) throws InterruptedException {
        // 容量为 1 的阻塞队列 + 核心/最大线程数均为 1
        BlockingQueue<runnable> queue = new ArrayBlockingQueue(1);
        ThreadPoolExecutor pool = new ThreadPoolExecutor(
            1, 1, 0, TimeUnit.SECONDS, queue,
            new ThreadPoolExecutor.CallerRunsPolicy() {{
                // 替换为自定义拒绝策略：直接 put
                @Override
                public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
                    try {
                        System.out.println("→ 进入拒绝策略，准备 put...");
                        queue.put(r); // ⚠️ 此处阻塞！
                        System.out.println("→ put 成功");
                    } catch (InterruptedException ignored) {}
                }
            }}
        );

        // 提交 3 个任务：第 1 个立即执行，第 2 个进队列，第 3 个触发拒绝策略
        pool.execute(() -> { sleep(1000); System.out.println("task-1"); });
        pool.execute(() -> { sleep(1000); System.out.println("task-2"); });
        System.out.println("准备提交 task-3...");
        pool.execute(() -> { System.out.println("task-3"); }); // ← 卡在这里！
        System.out.println("这句话永远不会打印");
        
        pool.shutdown();
    }
    static void sleep(long ms) { try { Thread.sleep(ms); } catch (InterruptedException e) {} }
}
</runnable>

关键现象与验证点

程序输出停在 “准备提交 task-3...” 后，不再打印下一行，也不打印 “→ 进入拒绝策略，准备 put...”
用 jstack 或 IDE 的 Debug 模式观察线程栈，会发现 main 线程处于 WAITING (on object monitor)，堆栈包含 ArrayBlockingQueue.put 和 rejectedExecution
说明：不是策略没触发，而是 put() 调用本身把 main 线程挂起了