如何修改Fixed ThreadPool最大线程数，实现满负载时新增线程？

嘿，这个需求太典型了！我之前也遇到过类似的场景，FixedThreadPool虽然能稳定维持固定线程数，但它的硬伤就是核心线程数和最大线程数完全绑定，再加上用的是无界队列，所以一旦所有线程都忙起来，新任务只会排队等着，绝对不会创建新线程。要实现你要的「保留初始线程+忙时动态扩容」的效果，咱们得直接自定义ThreadPoolExecutor，而不是用Executors提供的快捷方法。

核心思路拆解 #

FixedThreadPool的本质是new ThreadPoolExecutor(n, n, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>())——核心数=最大数，无界队列，所以永远不会触发扩容。咱们要改的就是：

• 把maximumPoolSize设成比corePoolSize大的值（比如你要初始8个，最大可以设16或者根据你的CPU/内存资源调整）
• 换掉无界队列，用**SynchronousQueue**（直接传递任务，不做队列缓冲），这样只要核心线程都在忙，新任务一来就会立刻创建新线程，直到达到最大线程数
• 给超出核心数的线程设置空闲超时时间，任务少了之后自动回收多余线程，回到初始的8个线程状态

代码示例 #

直接上可运行的代码，你可以根据自己的需求调整参数：

import java.util.concurrent.*;

public class DynamicThreadPoolExample {
    public static void main(String[] args) {
        // 自定义线程池：初始8个核心线程，最多扩容到16个，空闲线程60秒后回收
        ExecutorService dynamicThreadPool = new ThreadPoolExecutor(
            8,                  // corePoolSize：始终保留的初始线程数
            16,                 // maximumPoolSize：允许创建的最大线程数
            60L, TimeUnit.SECONDS, // keepAliveTime：超出核心数的线程空闲多久销毁
            new SynchronousQueue<>(), // 任务直接传递，不排队，核心忙就建新线程
            Executors.defaultThreadFactory(), // 默认线程工厂，也可以自定义线程名方便排查
            new ThreadPoolExecutor.AbortPolicy() // 拒绝策略：线程数满了就抛异常，可按需修改
        );

        // 测试：提交10个任务，看看会不会创建超过8个线程
        for (int i = 0; i < 10; i++) {
            int taskNum = i;
            dynamicThreadPool.submit(() -> {
                System.out.println("任务" + taskNum + "由线程" + Thread.currentThread().getName() + "执行");
                try {
                    // 模拟任务耗时
                    Thread.sleep(2000);
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
            });
        }

        // 记得用完关闭线程池
        dynamicThreadPool.shutdown();
    }
}

关键细节说明 #

1. 队列选择：如果用SynchronousQueue，任务不会排队，核心线程忙就直接建新线程，完全符合你「第9个任务立刻开新线程」的需求；如果需要一点缓冲，可以换成ArrayBlockingQueue并设置容量，但此时只有队列满了之后才会触发扩容，你得根据业务场景选。
2. 最大线程数设置：别贪大，一般建议根据CPU核心数来（比如CPU核心数*2），避免创建太多线程导致上下文切换开销过大，反而降低性能。
3. 拒绝策略：默认的AbortPolicy会抛出RejectedExecutionException，如果你的业务不能接受丢任务，可以换成CallerRunsPolicy（让提交任务的线程自己执行）、DiscardOldestPolicy（丢弃最老的排队任务）或者自定义拒绝策略。
4. 线程回收：设置keepAliveTime后，超出核心数的线程空闲到时间就会被回收，最终线程池会回到初始的8个核心线程状态，完美保留了你要的「初始线程保留」特性。

内容的提问来源于stack exchange，提问作者A.A