Executor 与线程池管理

从 JDK 5 起，ja va.util.concurrent 包里加入了 Executor 接口及其相关子类。

这套机制的出现，本质上就是为了更高效地处理线程并发，并把线程池管理这件事规范起来。

其中，Executor 下面有一个非常常用的子接口 ExecutorService。借助它，线程池的创建、调度和管理都会轻松很多。

通过Executor接口实现线程池管理的主要步骤

• （1）创建一个实现Runnable接口或者Callable接口的实现类，同时重写run()或者call()方法；
• （2）创建Runnable接口或者Callable接口的实现类对象；
• （3）使用Executors线程执行器类创建线程池；
• （4）使用ExecutorService执行器服务类的submit()方法将Runnable接口或者Callable接口的实现类对象提交到线程池进行管理；
• （5）线程任务执行完成后，可以使用shutdown()方法关闭线程池。

接下来通过一个案例，演示如何通过Executor接口来实现线程池管理，如文件1所示。

文件1 Example18.ja va

 1    import ja va.util.concurrent.*;
 2    //1、定义一个实现Callable接口的实现类
 3    class MyThread4 implements Callable<Object> {
 4        // 1.1、重写Callable接口的call()方法
 5        public Object call() throws Exception {
 6            int i = 0;
 7            while (i++ < 5) {
 8                System.out.println(Thread.currentThread().getName() 
 9                                    + "的call()方法在运行");
 10            }
 11            return i;
 12        }
 13    }
 14    public class Example18 {
 15        public static void main(String[] args) throws InterruptedException,
 16                                                        ExecutionException {
 17            // 2、创建Callable接口的实现类对象
 18            MyThread4 myThread4 = new MyThread4();
 19            // 3、使用Executors线程执行器类创建可扩展的线程池
 20            ExecutorService executor = Executors.newCachedThreadPool();
 21            // 4、将Callable接口实现类对象提交到线程池进行管理
 22            Future