`
milagro
  • 浏览: 13722 次
  • 性别: Icon_minigender_1
  • 来自: 杭州
社区版块
存档分类
最新评论

Executor/ExecutorService和ExecutorCompletionService

阅读更多

上篇文章讲到了Callable和Futre,这篇文章接着来说说执行器相关的接口和类。在JavaSE5之后,在API的java.util.concurrent包中给出了Executor这样一个接口。因为在Java7之前,JDK中这个接口最终都是以一个线程池ThreadPool的方式实现的,所以很多人也直接叫“线程池”。除了ThreadPool之外,还有ForkJoinPool实现,本文中,我们不妨直接翻译Executor为执行器。

Executor本身只是个接口,但和这个概念相关有很多类:包括Executor本身、ExecutorService、AbstractExecutorService、提供诸多静态方法的工具类Executors和相关的ExecutorCompletionService类,下面会对这些接口和类一一整理。除此之外,还有刚刚提到的ThreadPoolExecutor和ForkJoinPool,这两个类后面我们再说。

0. 综述和类层次结构

JavaSE5之后的任务执行器Executor实际上取代了Java并发开发中直接使用Thread对象的操作,以Command Pattern(命令模式)的设计模式实现,成为Java并发开发的主角。

Executor是最为抽象的接口,ExecutorService继而扩展了Executor, AbstractExecutorService 则给出了抽象的实现。

1. Executor

先看java.util.concurrent.Executor这个接口:

[java] view plaincopy在CODE上查看代码片派生到我的代码片
 
  1. public interface Executor {  
  2.     void execute(Runnable command);  
  3. }  

同Runnable和Callable一样简洁,只有一个方法。注意execute()这个方法只允许有一个Runnable参数,也就意味着想用前文中的Callable,需要做适配工作。

2. ExecutorService

java.util.concurrent.ExecutorService也是一个接口,扩展了Executor,提供了更为丰富的方法。

[java] view plaincopy在CODE上查看代码片派生到我的代码片
 
  1. public interface ExecutorService extendsExecutor {  
  2.     void shutdown();  
  3.     List shutdownNow();  
  4.     booleanisShutdown();  
  5.     boolean isTerminated();  
  6.     boolean awaitTermination(longtimeout, TimeUnit unit)  
  7.         throwsInterruptedException;  
  8.      Future submit(Callable task);  
  9.      Future submit(Runnable task, T result);  
  10.     Future<?> submit(Runnable task);  
  11.      List<Future> invokeAll(Collection<? extendsCallable> tasks)  
  12.         throwsInterruptedException;  
  13.      List<Future> invokeAll(Collection<? extendsCallable> tasks,  
  14.                                   longtimeout, TimeUnit unit)  
  15.         throwsInterruptedException;  
  16.      T invokeAny(Collection<? extendsCallable> tasks)  
  17.         throwsInterruptedException, ExecutionException;  
  18.      T invokeAny(Collection<? extendsCallable> tasks,  
  19.                     longtimeout, TimeUnit unit)  
  20.         throwsInterruptedException, ExecutionException, TimeoutException;  
  21. }  

一共12个方法,其中一部分是和执行器生命周期相关的方法,而另一部分则是以各种方式提交要执行的任务的方法。像submit()就是提交任务的一个方法,在实现中做了适配的工作,无论参数是Runnable还是Callable,执行器都会正确执行。当然,这实际上用到的是前文提过的RunnableFuture的实现类FutureTask。

3. AbstractExecutorService

java.util.concurrent.AbstractExecutorService这个类是ExecutorService的一个抽象实现。其中,提交任务的各类方法已经给出了十分完整的实现。之所以抽象,是因为和执行器本身生命周期相关的方法,在此类中并未给出任何实现,需要子类扩展完善。

4. Executors
这个类同Arrays和Collections很类似,java.util.concurrent.Executors是个工具类,提供了很多静态的工具方法。其中很多对于执行器来说就是初始化构建用的工厂方法。其中部分方法名整理成如下列表:

  • 重载实现的newFixedThreadPool()
  • 重载实现的newSingleThreadExecutor()
  • 重载实现的newCachedThreadPool()
  • 重载实现的newSingleThreadScheduledExecutor()
  • 重载实现的newScheduledThreadPool()

这些方法返回的ExecutorService对象最终都是由ThreadPoolExecutor实现的,根据不同的需求以不同的参数配置,或经过其它类包装。其中,Executors中的一些内部类就是用来做包装用的。

Executors还提供了这样两个静态重载的方法:

 

[java] view plaincopy在CODE上查看代码片派生到我的代码片
 
  1. publicstatic ExecutorService unconfigurableExecutorService(ExecutorService executor);  
  2. publicstatic ScheduledExecutorService unconfigurableScheduledExecutorService(ScheduledExecutorService executor);  

 

这两个方法对参数中的executor做了包装,保证了Executor在初始化构造后不再可配置。

此外,Executors类中还有静态的defaultThreadFactory()方法,免去了自己构造ThreadFactory或是需要线程时对Thread类的new操作。

关于更多Executors类中工具方法的使用,还是建议去看API JavaDoc和JDK源码。

5. ExecutorCompletionService

前一篇文章提过了CompletionService这个接口,和执行器相关的,java.util.concurrent中提供了这个接口的一个实现,就是ExecutorCompletionService。

这个实现类主要做的就是将执行完成的任务结果放到阻塞队列中,这样等待结果的线程,如执行take()方法会得到结果并恢复执行。

ExecutorCompletionService有3个属性:

  • AbstractExecutorService类的对象aes
  • Executor类的对象executor
  • BlockingQueue<Future<V>>的completionQueue

通常,如果executor是AbstractExecutorService的一个实现,则将其赋值给aes属性,否则赋值为null。

在这个类中,executor负责执行任务,而aes则负责做适配处理,返回包装好任务的FutureTask对象。

这里面有一个对于实现功能很重要的内部类QueueingFuture,实现如下:

[java] view plaincopy在CODE上查看代码片派生到我的代码片
 
  1. private class QueueingFuture extendsFutureTask {  
  2.     QueueingFuture(RunnableFuture task) {  
  3.         super(task,null);  
  4.         this.task = task;  
  5.     }  
  6.     protectedvoid done() { completionQueue.add(task); }  
  7.     privatefinal Future task;  
  8. }  

主要是扩展了FutureTask的done方法,将执行结果放入BlockingQueue中。 

Executor/ExecutorService和ExecutorCompletionService

分享到:
评论

相关推荐

    java 中Executor, ExecutorService 和 Executors 间的不同

    Java 中 Executor, ExecutorService 和 Executors 的不同 Java 中的 Executor, ExecutorService 和 Executors 是 Java Executor 框架的重要组件,用于提供线程池的功能。在 Java 1.5 之后,Executor 框架提供了多种...

    Executor,Executors,ExecutorService比较.docx

    【Executor、Executors和ExecutorService详解】 在Java并发编程中,`Executor`、`Executors`和`ExecutorService`是核心组件,它们帮助开发者高效管理线程资源,提高程序的并发性能。理解这三个概念的区别和用途是...

    java中Executor,ExecutorService,ThreadPoolExecutor详解

    主要介绍了java中Executor,ExecutorService,ThreadPoolExecutor详解的相关资料,需要的朋友可以参考下

    常见的tensorflow-gpu2.x缺失dll(cublas64-11.dll&cublasLt64-11.dll等)

    2023-06-09 22:23:25.593906: W tensorflow/stream_executor/platform/default/dso_loader.cc:64] Could not load dynamic library 'cublas64_11.dll'; dlerror: cublas64_11.dll not found 2023-06-09 22:23:25....

    重新编译好的contain-executor文件,指向/etc/hadoop/container-executor.cfg

    hadoop自带的Container-executor在配置yarn-kerberos时存在问题,以及在配置cgroup时需要把container-executor.cfg的上级目录拥有者均改为root,带来不便。 所以需要重新编译Container-executor,这边提供重新编译好...

    java并发编程:Executor、Executors、ExecutorService.docx

    Java并发编程中的Executor、Executors和ExecutorService是Java并发编程框架的重要组成部分,它们为开发者提供了高效管理和控制线程执行的工具。以下是对这些概念的详细解释: 1. Executor: Executor是一个接口,它...

    重新编译的Container-executor 目录文件路径/etc/container-executor.cfg

    hadoop自带的Container-executor在配置yarn-kerberos时存在问题,这边给出编译后的Container-executor,默认加载配置文件路径/etc/container-executor.cfg,大家不用再重新编译了

    Nagios Remote Plugin Executor/PERL-开源

    Nagios远程插件执行器/ PERL(NRPEP)是客户端/服务器接口的PERL实现,旨在为Nagios监视系统提供一种远程执行插件的安全方法。

    Opencv4.0.0含opencv_contrib(win10+vs2017编译版)

    Opencv4.0.0含opencv_contrib(win10+vs2017编译版) 解压(笔者将其全部解压在了C:\Program Files内) 将glog,glag,suitesparse,ceres的相关bin目录加到系统变量中的path中 将Eigen的库目录加入vs的附加库目录中 ...

    SQLExecutor

     为方便管理软件数据库的维护,系统将用于维护数据库的 SQL 程序划分为事务和任务来进行管理。事务是最基本的单位,一个用于维护数据库的任务包含一个或者多个事务。任务不仅包含事务,同时也包含了事务执行的顺序...

    ExecutorService与CompletionService对比详解.docx

    ExecutorService 是一个接口,它是java.util.concurrent.Executor 接口的扩展,提供了一组方法来管理和控制线程池,包括提交任务、关闭线程池以及获取任务执行结果。而CompletionService则是一个接口,它提供了一种...

    基础技术部牛路《Java多线程入阶分享》纯干货

    2.Executor:ExecutorService和Future 3.阻塞队列:put和take、offer和poll、drainTo 4.线程间通信:lock、condition、wait、notify、notifyAll 5.Lock-free:atomic、concurrentMap.putIfAbsent、...

    Executor框架使用详解

    基于`Executor`,`ExecutorService`接口提供了更丰富的功能,如关闭线程池的`shutdown()`和`shutdownNow()`方法,以及管理和控制任务执行的方法,如`submit()`、`invokeAll()`和`invokeAny()`。`ExecutorService`...

    Java并发程序设计教程

    2、Executor :ExecutorService和Future ☆☆☆ 3、阻塞队列: put和take、offer和poll、drainTo 4、线程间的协调手段:lock、condition、wait、notify、notifyAll☆☆☆ 5、Lock-free: atomic、concurrentMap....

    Java编程并发程序设计

    2、Executor :ExecutorService和Future ☆☆☆ 3、阻塞队列: put和take、offer和poll、drainTo 4、线程间的协调手段:lock、condition、wait、notify、notifyAll☆☆☆ 5、Lock-free: atomic、concurrentMap....

    Android Executor线程池

    在`Executor`框架中,`ExecutorService`是核心接口,它扩展了`Executor`接口并添加了一些用于管理和控制线程池的方法,如提交任务、关闭线程池等。Android开发者通常会使用`ThreadPoolExecutor`或`...

    ExecutorService的execute和submit方法

    `ExecutorService`通过`execute()`和`submit()`这两个方法来提交任务进行执行。理解并熟练运用这两个方法对于优化并发性能至关重要。 `execute()`方法: `execute(Runnable command)`是`ExecutorService`最基础的...

    spark:Executor分配详解

    ### Spark:Executor分配详解 #### 一、Spark的资源分配机制概述 在深入探讨Executor的分配之前...在实际部署Spark集群时,开发者应该根据具体的应用场景和资源限制来调整Executor的相关配置,以实现最佳的性能表现。

    itmat-broker

    #Develop分支 要部署该应用程序,需要安装一些程序: 0.先决条件 ...cp packages/itmat-job-executor/config/config.sample.json packages/itmat-job-executor/config/config.json cp packages/itma

Global site tag (gtag.js) - Google Analytics