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
-
如果当前正在工作的线程（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循环里，只要有任务就要一直执行下去
