线程池的执行流程

线程池的执行流程是一个系统且有序的过程，它主要涉及到任务的提交、线程的分配、任务的执行以及线程的回收等多个环节。以下是对线程池执行流程的详细阐述：

一、任务提交

1. 提交任务：当一个新的线程任务被提交到线程池时，线程池会首先尝试在线程池中分配一个空闲线程来执行这个任务。

二、线程分配与任务执行

1. 检查空闲线程：
   • 如果线程池中存在空闲线程，则直接分配一个空闲线程来执行新任务。
   • 如果线程池中没有空闲线程，则进入下一步判断。
2. 判断核心线程数：
   • 线程池会检查当前“存活线程数”是否小于核心线程数（corePoolSize）。
     • 如果小于核心线程数，则线程池会创建一个新的核心线程来执行新任务。
     • 如果不小于核心线程数，则进入下一步判断。
3. 检查工作队列：
   • 线程池会检查工作队列（BlockingQueue）是否已满。
     • 如果工作队列未满，则将新任务放入工作队列中等待，直到有空闲线程取出并执行。
     • 如果工作队列已满，则进入下一步判断。
4. 判断最大线程数：
   • 线程池会检查当前“存活线程数”是否小于最大线程数（maximumPoolSize）。
     • 如果小于最大线程数，则线程池会创建一个新的非核心线程来执行新任务。
     • 如果不小于最大线程数，则进入拒绝策略环节。
5. 也就是说，如果当前核心线程数是10，最大线程数是20，工作队列长度为10，当有30个任务过来时，会先执行1-10个任务，再执行第21-30个任务，然后才是第11-20，可以由以下代码进行验证

   public class CustomPool {
       public static void main(String[] args) {
           //自定义线程池
           ExecutorService threadPool = new ThreadPoolExecutor(
                   10,
                   20,
                   0L,
                   TimeUnit.SECONDS,
                   new ArrayBlockingQueue<Runnable>(10),
                   Executors.defaultThreadFactory(),
                   new ThreadPoolExecutor.AbortPolicy()
           );
           class MyTask implements Runnable {
               int i = 0;
               public MyTask(int i){
                   this.i = i;
               }
   
               @Override
               public void run() {
                   try {
                       System.out.println(Thread.currentThread().getName() + "做第" + i + "个项目");
                   } catch (Exception e) {
                       e.printStackTrace();
                   }
               }
           }
           try {
               for (int i = 1; i <= 100;i++){
                   MyTask task = new MyTask(i);
                   threadPool.execute(task);
               }
           } catch (Exception e) {
               e.printStackTrace();
           } finally {
               threadPool.shutdown();
           }
       }
   }
   

三、拒绝策略

• 当工作队列已满，且当前线程数已达到最大线程数时，如果再有新任务提交到线程池，则会触发拒绝策略。拒绝策略可以是以下几种之一（根据JDK实现）：
  • AbortPolicy：直接抛出RejectedExecutionException异常，阻止系统正常运行。
  • CallerRunsPolicy：用调用者所在的线程来执行任务，即不会在线程池中创建新线程，也不会丢弃任务。
  • DiscardPolicy：不处理新任务，直接丢弃掉。
  • DiscardOldestPolicy：丢弃队列中最老的一个任务，然后尝试再次提交当前任务。
  • 自定义拒绝策略：实现RejectedExecutionHandler接口，自定义处理逻辑。