首页技术文章正文

Executor接口实现线程池管理

更新时间:2022-05-20 来源:黑马程序员 浏览量:

从JDK5开始,在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接口来实现线程池管理,如例10-18所示。

例10-18 Example18.java

import java.util.concurrent.*;
//1.定义一个实现Callable接口的实现类
class MyThread4 implements Callable<Object>{
    //1.1重写callable接口的cal1()方法
    public Object call () throwa Exception {
        int i=0;
        while (i++<5)(
            System.out.println(Thread.currentThread().getName()
                               +“的cal1()方法在运行“);
        }
        return 1;
     } 
 }
public class Examplel8 {
   public static void main(String[] args) throws InterruptedException,
                                                 ExecutionException (
       //2.创建Callable接口的实现类对象
       MyThread4 myThread4 =new MyThread4();
       //3.使用Executors线程执行器类创建可扩展的线程池
       ExecutorService executor =Executors.newCachedThreadPool () ;
       //4.将cal1able接口实现类对象提交到线程池进行管理
       Future<Object>resultl=executor.submit(myThread4);
       Future<Object>result2=executor.submit(myThread4);
       //5.关闭线程池
       executor. shutdown ();
       //对于有返回值的线程任务,获取执行结果
       System.out.println("thread-1返回结果:"+result1.get());
       System.out.println("thread-2返回结果:"+result2.get());
   }
}

1653041413356_2222.jpg

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

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

1653041340325_方法声明.png

分享到:
在线咨询 我要报名
和我们在线交谈!