学科分类
目录
Java基础

Executor接口实现线程池管理

从JDK 5开始,在java.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.java

 1    import java.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<Object> result1 = executor.submit(myThread4);
 23            Future<Object> result2 = executor.submit(myThread4);
 24            // 5、关闭线程池
 25            executor.shutdown();
 26            // 对于有返回值的线程任务,获取执行结果
 27            System.out.println("thread-1返回结果:" + result1.get());
 28            System.out.println("thread-2返回结果:" + result2.get());
 29        }
 30    }

运行结果如图1所示。

图1 运行结果

从图1可以看出,文件1所示的案例创建了一个自定义的线程池executor(线程池默认生成名称为pool-1),在该线程池中管理有两个默认生成名称的线程thread-1和thread-2,同时还可以获取这两个线程的执行结果。

在文件1所示的案例中,线程池是通过Executors的newCachedThreadPool()方法创建的,Executors是JDK 5中增加的线程执行器工具类,提供了4种方法来创建用于不同需求的线程池,如表1所示。

表1 Executors创建线程池的方法

方法声明 功能描述
ExecutorService newCachedThreadPool() 创建一个可扩展线程池的执行器。这个线程池执行器适用于启动许多短期任务的应用程序
ExecutorService newFixedThreadPool( int nThreads) 创建一个固定线程数量线程池的执行器。这种线程池执行器可以很好的控制多线程任务,也不会导致由于响应过多导致的程序崩溃
ExecutorService newSingleThreadExecutor() 在特殊需求下创建一个只执行一个任务的单个线程
ScheduledExecutorService newScheduledThreadPool(int corePoolSize) 创建一个定长线程池,支持定时及周期性任务执行
点击此处
隐藏目录