这是一个非常实战且关键的线程池调优问题。Java 的线程池默认行为是：

当任务数超过 corePoolSize 时，任务会被放入任务队列，而不是立即创建新线程（即使还没达到 maximumPoolSize）

---

我们的目标是：

“任务数超过核心线程数时，不让任务排队，而是马上启用最大线程数内的新线程来处理任务”

---

实现方法：使用 SynchronousQueue + 自定义 ThreadPoolExecutor

原因：

• 默认如 LinkedBlockingQueue 是有队列容量的阻塞队列，会优先排队而不是创建新线程；
• SynchronousQueue 是无缓冲队列，不会保存任务，而是将任务直接交给线程处理；
• 所以，只要没有空闲线程，线程池就会尝试创建新线程，直到达到 maximumPoolSize。

---

推荐代码示例

import java.util.concurrent.*;

public class ForceMaxThreadPool {

    public static void main(String[] args) {
        ThreadPoolExecutor executor = new ThreadPoolExecutor(
                2,                      // corePoolSize
                5,                      // maximumPoolSize
                60L, TimeUnit.SECONDS, // keepAliveTime
                new SynchronousQueue<>(), // ✅ 无队列，任务不会排队
                Executors.defaultThreadFactory(),
                new ThreadPoolExecutor.AbortPolicy() // 可换成 CallerRunsPolicy 等
        );

        // 提交 6 个任务（> maxPoolSize = 5 会被拒绝）
        for (int i = 0; i < 6; i++) {
            int taskId = i;
            executor.execute(() -> {
                System.out.println(Thread.currentThread().getName() + " 执行任务 " + taskId);
                try {
                    Thread.sleep(3000);
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
            });
        }

        executor.shutdown();
    }
}

输出观察：

• 线程池立即创建新线程处理任务
• 不排队，只要没达到最大线程数就创建新线程
• 超过最大线程数的任务将触发拒绝策略

---

拓展说明：为什么默认会排队？

Java 的默认 newFixedThreadPool() 使用的是 LinkedBlockingQueue，它是无界队列（Integer.MAX_VALUE），所以除非任务爆满导致内存问题，否则不会触发新线程的创建或拒绝策略。

---

注意点

事项	建议
使用 SynchronousQueue 才能跳过排队
合理设置 maximumPoolSize，防止线程爆炸
配置合适的拒绝策略（如 CallerRunsPolicy）来避免丢任务
可配合线程池监控工具观察动态线程数变化

---

参考文档

• ThreadPoolExecutor 官方文档
• 《Java 并发编程实战》第 8 章：线程池设计
• Java 源码分析 ThreadPoolExecutor 策略

---

总结

想要“任务数超过核心线程数时立即创建新线程”：

• 必须使用 SynchronousQueue 替代任务队列；
• 让线程池直接扩容线程，而不是先排队；
• 这是实现类似缓存线程池行为的最佳实践方式之一。

---

更多详细内容请关注其他相关文章！