FixedThreadPool最大线程数是多少？自制该线程池的实现疑问

FixedThreadPool 最多创建多少线程？ #

首先明确：Executors.newFixedThreadPool(N) 创建的线程池，最多只会存在N个工作线程。

背后的逻辑是：它底层封装的 ThreadPoolExecutor，核心线程数（corePoolSize）和最大线程数（maximumPoolSize）都被设置为N，而且使用无界的 LinkedBlockingQueue 存储等待的任务。当提交的任务数超过N时，新任务会被放入队列等待，不会触发创建新线程（因为最大线程数等于核心线程数，线程池不会扩容）。只有当核心线程因异常退出时，线程池才会创建新线程补充，但总线程数始终维持在N个。

自定义实现FixedThreadPool时，避免重复创建线程的关键 #

你遇到的“总是创建新Thread对象”的问题，核心是没做到线程复用——FixedThreadPool的核心就是用固定数量的线程循环处理任务，而非每次有任务就新建线程。

下面给你一个极简的自定义实现示例，核心思路是用阻塞队列存储任务，初始化时就创建好固定数量的工作线程，让这些线程循环从队列中取任务执行：

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

public class MyFixedThreadPool {
    // 存储等待执行的任务
    private final BlockingQueue<Runnable> taskQueue;
    // 固定数量的工作线程数组
    private final Thread[] workerThreads;

    public MyFixedThreadPool(int nThreads) {
        taskQueue = new LinkedBlockingQueue<>();
        workerThreads = new Thread[nThreads];

        // 初始化并启动所有工作线程
        for (int i = 0; i < nThreads; i++) {
            workerThreads[i] = new Thread(() -> {
                try {
                    // 线程持续运行，直到被中断
                    while (!Thread.currentThread().isInterrupted()) {
                        // 从队列取出任务，队列为空时阻塞等待
                        Runnable task = taskQueue.take();
                        task.run();
                    }
                } catch (InterruptedException e) {
                    // 捕获中断信号，结束线程循环
                    Thread.currentThread().interrupt();
                }
            });
            workerThreads[i].start();
        }
    }

    // 提交任务的方法
    public void execute(Runnable task) {
        try {
            // 将任务放入队列，等待工作线程处理
            taskQueue.put(task);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }

    // 可选：关闭线程池的方法
    public void shutdown() {
        for (Thread thread : workerThreads) {
            thread.interrupt();
        }
    }
}

这个实现的关键细节：

• 阻塞队列：LinkedBlockingQueue 会自动处理任务的等待逻辑——当所有工作线程都在忙时，新提交的任务会被放入队列，直到有空闲线程来取。
• 线程复用：初始化时就创建好N个线程，这些线程会一直循环从队列取任务执行，不会因为任务完成就销毁，除非调用shutdown()中断它们。
• 避免新建线程：execute()方法只是把任务加入队列，不会创建新线程，完全由预先创建好的工作线程处理任务。

如果你之前的实现是每次调用execute()都new Thread(task).start()，那自然会不断创建新线程，这就违背了FixedThreadPool“固定线程数、复用线程”的核心设计啦。

内容的提问来源于stack exchange，提问作者Just Another Developer