Java多线程--线程池执行流程

Executor框架的最大优点是把任务的提交和执行解耦。要想执行任务，只需把任务描述清楚，提交即可。这个任务是怎么被执行的，被谁执行的，什么时候执行的，不用关心。即，提交一个Callable对象给ExecutorService（如最常用的线程池ThreadPoolExecutor），得到一个Future对象，调用Future对象的get方法等待执行结果。

// es管理着一个有5个线程的线程池
ExecutorService es = Executors.newFixedThreadPool(5);
     //提交作业给es，任务内容封装在Callable中，约定好了输出的类型是String。
     String outputs = es.submit(
        new Callable<String>() {
             public String call() throws Exception {                            
                 return "I am a task, which submited by es, and run by those workers";
             }
        //提交后等待结果，到底是5个线程中哪个完成的任务，不用关心
         }).get();
System.out.println(outputs);

下面通过源码来了解一下任务是如何被执行的

Paste_Image.png

接口ExecutorService继承自Executor

Paste_Image.png
他定义了完整的线程池的行为，可以接受提交任务、执行任务、关闭服务。抽象类AbstractExecutorService类实现了ExecutorService接口
Paste_Image.png

也实现了接口定义的默认行为。

1)提交任务submit：构造好一个FutureTask对象后，调用execute()方法执行任务。一共有3种带不同参数类型的submit，但最后都会返回一个FutureTask

Paste_Image.png
Paste_Image.png

2)执行任务Executor：该方法在抽象类AbstractExecutorService的子类ThreadPoolExecutor中实现的

Paste_Image.png
线程池的接收任务、维护工作线程的策略都在这个类中。
执行execute分3步：
Paste_Image.png

1. 如果当前正在工作的线程（workerCountOf）小于核心线程corePoolSize，就创建一个新线程（addWorker）。2. 如果任务被放入了队列，还需要检测是否能创建新线程（因为线程可能会在上次检查后死亡（isRunning））或线程池是否被关闭，如果状态不正确，需要回滚入列并停止或创建新线程。3. 如果任务不能被放入队列，就尝试创建新线程，如果创建失败，就拒绝此任务（reject）

   
   Paste_Image.png
   

   3)工作线程的run方法
   ThreadPoolExecutor有两个最重要的集合属性，分别是存储接收任务的任务队列

   
   Paste_Image.png
   用来干活的集合
   Paste_Image.png
   

   worker是ThreadPoolExecutor的一个内部类，实现了Runnable接口

   
   Paste_Image.png
   他的run方法：
   Paste_Image.png
   Paste_Image.png
   可以看到工作线程就是在一直调用getTask方法获取任务，然后调用 task.run()方法执行任务，这里才是真正的执行任务。这些操作全部是在while循环里，只要有任务就要一直执行下去