ThreadPoolExecutor 自定义线程池

public ThreadPoolExecutor(int corePoolSize,
                          int maximumPoolSize,
                          long keepAliveTime,
                          TimeUnit unit,
                          BlockingQueue<Runnable> workQueue) {
    this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,
         Executors.defaultThreadFactory(), defaultHandler);
}

参数	功能
corePoolSize	the number of threads to keep in the pool, even if they are idle.
maximumPoolSize	the maximum number of threads to allow in the pool.
keepAliveTime	when the number of threads is greater than the core, this is the maximum time that excess idle threads will wait for new tasks before terminating.
unit	the time unit for the {@code keepAliveTime} argument
workQueue	the queue to use for holding tasks before they are executed. This queue will hold only the {@code Runnable} tasks submitted by the {@code execute} method.

---

Java线程池的工作流程

前置条件	执行步骤	举例
首先检测 线程池运行状态	如果不是RUNNING，则直接拒绝，线程池要保证在RUNNING的状态下执行任务。	当试图通过excute方法将一个Runnable任务添加到线程池中时，按照如下顺序来处理
如果workerCount < corePoolSize	则创建并启动一个线程来执行新提交的任务。	如果线程池中的线程数量少于corePoolSize，即使线程池中有空闲线程，也会创建一个新的线程来执行新添加的任务
如果workerCount >= corePoolSize，线程池内的阻塞队列未满	则将任务添加到该阻塞队列中。	如果线程池中的线程数量大于等于corePoolSize，但缓冲队列workQueue未满，则将新添加的任务放到workQueue中，按照FIFO的原则依次等待执行（线程池中有线程空闲出来后依次将缓冲队列中的任务交付给空闲的线程执行）
如果workerCount >= corePoolSize，线程池内的阻塞队列已满，但 workerCount < maximumPoolSize	则创建并启动一个线程来执行新提交的任务。	如果线程池中的线程数量大于等于corePoolSize，且缓冲队列workQueue已满，但线程池中的线程数量小于maximumPoolSize，则会创建新的线程来处理被添加的任务
如果 workerCount >= corePoolSize，线程池内的阻塞队列已满，且workerCount >= maximumPoolSize	则根据拒绝策略来处理该任务, 默认的处理方式是直接抛异常。	如果线程池中的线程数量等于了maximumPoolSize，有4种处理方式（该构造方法调用了含有5个参数的构造方法，并将最后一个构造方法为RejectedExecutionHandler类型，它在处理线程溢出时有4种方式，这里不再细说，要了解的，自己可以阅读下源码）
注意： 当线程池中的线程数量大于corePoolSize时，如果里面有线程的空闲时间超过了keepAliveTime，就将其移除线程池，这样可以动态地调整线程池中线程的数量。

---

线程任务

public class Task implements Runnable {
    private final String name;

    public Task(String name) {
        this.name = name;
    }

    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() + " → " + name + " Start Time = " + new Date());
        processCommand();
        System.out.println(Thread.currentThread().getName() + " → " + name + " End   Time = " + new Date());
    }

    private void processCommand() {
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

自定义线程池

public class CustomThreadPool {
    public static void main(String[] args) {
        System.out.println(Thread.currentThread().getName() + "线程: Start at: " + new Date());

        // 创建等待队列
        BlockingQueue<Runnable> blockingQueue = new ArrayBlockingQueue<>(20);

        // 创建线程池、池中保存的线程数为3，允许的最大线程数为5
        ThreadPoolExecutor pool = new ThreadPoolExecutor(3, 5, 50, TimeUnit.MILLISECONDS, blockingQueue);

        // 创建七个任务
        // 每个任务会在一个线程上执行
        for (int i = 1; i < 10; i++) {
            System.out.println("添加了第" + i + "个任务类");
            pool.execute(new Task("线程任务" + i));
        }

        // 关闭线程池
        pool.shutdown();

        System.out.println(Thread.currentThread().getName() + "线程: 打卡：" + new Date());

        long i = 0;
        while (!pool.isTerminated()) {
            // wait for all tasks to finish
            i++;
        }

        System.out.println(Thread.currentThread().getName() + "线程: Finished all threads at：" + new Date() + ". isTerminated 判断次数 " + i);
    }
}

---

执行结果分析

执行结果
main线程: Start at: Fri May 19 18:28:52 CST 2023	进入main线程
添加了第1个任务类	构建任务放入线程池
添加了第2个任务类
添加了第3个任务类
添加了第4个任务类
添加了第5个任务类
添加了第6个任务类
添加了第7个任务类
添加了第8个任务类
添加了第9个任务类
添加了第10个任务类
main线程: 打卡：Fri May 19 18:28:52 CST 2023	主线程打个卡
pool-1-thread-2 → 线程任务2 Start Time = Fri May 19 18:28:52 CST 2023	线程池开始分配线程执行线程任务
pool-1-thread-1 → 线程任务1 Start Time = Fri May 19 18:28:52 CST 2023
pool-1-thread-3 → 线程任务3 Start Time = Fri May 19 18:28:52 CST 2023
pool-1-thread-2 → 线程任务2 End Time = Fri May 19 18:28:55 CST 2023
pool-1-thread-2 → 线程任务4 Start Time = Fri May 19 18:28:55 CST 2023
pool-1-thread-3 → 线程任务3 End Time = Fri May 19 18:28:55 CST 2023
pool-1-thread-1 → 线程任务1 End Time = Fri May 19 18:28:55 CST 2023
pool-1-thread-1 → 线程任务6 Start Time = Fri May 19 18:28:55 CST 2023
pool-1-thread-3 → 线程任务5 Start Time = Fri May 19 18:28:55 CST 2023
pool-1-thread-2 → 线程任务4 End Time = Fri May 19 18:28:58 CST 2023
pool-1-thread-2 → 线程任务7 Start Time = Fri May 19 18:28:58 CST 2023
pool-1-thread-3 → 线程任务5 End Time = Fri May 19 18:28:58 CST 2023
pool-1-thread-1 → 线程任务6 End Time = Fri May 19 18:28:58 CST 2023
pool-1-thread-3 → 线程任务8 Start Time = Fri May 19 18:28:58 CST 2023
pool-1-thread-1 → 线程任务9 Start Time = Fri May 19 18:28:58 CST 2023
pool-1-thread-2 → 线程任务7 End Time = Fri May 19 18:29:01 CST 2023
pool-1-thread-2 → 线程任务10 Start Time = Fri May 19 18:29:01 CST 2023
pool-1-thread-3 → 线程任务8 End Time = Fri May 19 18:29:01 CST 2023
pool-1-thread-1 → 线程任务9 End Time = Fri May 19 18:29:01 CST 2023
pool-1-thread-2 → 线程任务10 End Time = Fri May 19 18:29:04 CST 2023
main线程: Finished all threads at：Fri May 19 18:29:04 CST 2023. isTerminated 判断次数 25692088316	所有线程全部执行完毕
从结果中可以看出，10 个任务是在线程池的 3 个线程上执行的