Java Executor 框架的实例详解

大多数并发都是通过任务执行的方式来实现的。

一般有两种方式执行任务：串行和并行。

class SingleThreadWebServer {
 public static void main(String[] args) throws Exception {
  ServerSocket socket = new ServerSocket(80);
  while(true) {
   Socket conn = socket.accept();
   handleRequest(conn);
  }
 }
}
class ThreadPerTaskWebServer {
 public static void main(String[] args) throws Exception {
  ServerSocket socket = new ServerSocket(80);
  while(true) {
   final Socket conn = socket.accept();
   Runnable task = new Runnable() {
    public void run() {
     handleRequest(conn);
    }
   };
   new Thread(task).start();
  }
 }
}

当然上面的这两种方式都是有问题的。单线程的问题就是并发量会是瓶颈，多线程版本就是无限制的创建线程会导致资源不足问题。

Executor 框架

任务是一组逻辑工作单元，而线程是使任务异步执行的机制。

JDK 提供了 Executor 接口：

public interface Executor {
  void execute(Runnable command);
}

虽然 Executor 接口比较简单，但是却是异步任务执行框架的基础，该框架能支持多种不同类型的任务执行策略。它提供了一种标准的方式把任务的提交过程与执行过程进行了解耦。用 Runnable 来代表任务。Executor 的实现提供了对生命周期的支持以及统计信息应用程序管理等机制。

Executor 是基于生产者消费者模式的，提交任务的操作相当于生产者，执行任务的线程相当于消费。

基于 Executor 的 WebServer 例子如下：

public class TaskExecutorWebServer {
 private static final int NTHREADS = 100;
 private static final Executor exec = Executors.newFixedThreadPool(NTHREADS);
 public static void main(String[] args) throws Exception {
  ServerSocket serverSocket = new ServerSocket(80);
  while (true) {
   final Socket conn = serverSocket.accept();
   Runnable task = new Runnable() {
    @Override
    public void run() {
     handleRequest(conn);
    }
   };
   exec.execute(task);
  }
 }
}

另外可以自己实现 Executor 来控制是并发还是并行的，如下面代码：

/**
 * 执行已提交的 Runnable 任务的对象。
 * 此接口提供一种将任务提交与每个任务将如何运行的机制（包括线程使用的细节、调度等）分离开来的方法。
 * 通常使用 Executor 而不是显式地创建线程。
 *
 *
 * @author renchunxiao
 *
 */
public class ExecutorDemo {
 public static void main(String[] args) {
  Executor executor = new ThreadExecutor();
  executor.execute(new Runnable() {
   @Override
   public void run() {
    // do something
   }
  });
  Executor executor2 = new SerialExecutor();
  executor2.execute(new Runnable() {
   @Override
   public void run() {
    // do something
   }
  });
 }
}
/**
 * 创建一个线程来执行 command
 *
 * @author renchunxiao
 *
 */
class ThreadExecutor implements Executor {
 @Override
 public void execute(Runnable command) {
  new Thread(command).start();
 }
}
/**
 * 串行执行 command
 *
 * @author renchunxiao
 *
 */
class SerialExecutor implements Executor {
 @Override
 public void execute(Runnable command) {
  command.run();
 }
}

线程池

线程池就是线程的资源池，可以通过 Executors 中的静态工厂方法来创建线程池。

• newFixedThreadPool。创建固定长度的线程池，每次提交任务创建一个线程，直到达到线程池的最大数量，线程池的大小不再变化。
• newSingleThreadExecutor。单个线程池。
• newCachedThreadPool。根据任务规模变动的线程池。
• newScheduledThreadPool。创建固定长度的线程池，以延迟或定时的方式来执行任务。
  

JVM 只有在所有非守护线程全部终止后才会退出，所以，如果无法正确的关闭 Executor，那么 JVM 就无法结束。

为了解决执行服务的生命周期问题，有个扩展 Executor 接口的新接口 ExecutorService。

public interface ExecutorService extends Executor {
 void shutdown();
 List<Runnable> shutdownNow();
 boolean isShutdown();
 boolean isTerminated();
 boolean awaitTermination(long timeout, TimeUnit unit)
  throws InterruptedException;
 <T> Future<T> submit(Callable<T> task);
 <T> Future<T> submit(Runnable task, T result);
 Future<?> submit(Runnable task);
 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
  throws InterruptedException;
 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
         long timeout, TimeUnit unit)
  throws InterruptedException;
 <T> T invokeAny(Collection<? extends Callable<T>> tasks)
  throws InterruptedException, ExecutionException;
 <T> T invokeAny(Collection<? extends Callable<T>> tasks,
     long timeout, TimeUnit unit)
  throws InterruptedException, ExecutionException, TimeoutException;
}

ExecutorService 生命周期有三种状态：运行、关闭、已终止。ExecutorService 在初始创建时处于运行状态。shutdown 方法会平缓关闭：不在接受新的任务，并且等待已经执行的任务执行完成(包括那些还未开始的任务)。shutdownNow 方法将粗暴关闭：它将尝试取消所有运行中的任务，并且不再启动队列中尚未开始的任务。所有任务都执行完成后进入到已终止状态。

Callable 和 Future

Executor 框架使用 Runnable 作为基本的任务表示形式。Runnable 是一种有局限性的抽象，它的 run 方法不能返回值和抛出一个受检查异常。

许多任务实际上是存在延时的计算，例如数据库查询，从网络获取资源。对于这些任务，Callable 是更好的抽象，它认为 call 将返回一个值，并且可能抛出异常。

Executor 执行的任务有四个生命周期阶段:创建、提交、开始和完成。由于有些任务需要很长时间有可能希望取消，在 Executor 框架当中，已提交未开始的任务可以取消。

Future 表示一个任务的生命周期，并且提供了相应的方法来判断是否已经完成或取消，以及获取任务的结果和取消任务等。

如有疑问请留言或者到本站社区交流讨论，感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！

# Java  # Executor  # 的框架学习  # 的详解  # Java中Executor接口用法总结  # Java并发编程之Executors类详解  # Java线程池ThreadPoolExecutor原理及使用实例  # Java并发框架:Executor API详解  # Java ExecutorService四种线程池使用详解  # Java并发编程之Executor接口的使用  # 方法来  # 创建一个  # 抛出  # 都是  # 是一种  # 有个  # 是有  # 却是  # 有可能  # 如有  # 才会  # 可以通过  # 希望能  # 还未  # 有两种  # 谢谢大家  # 这两种  # 来实现  # 它将  # 很长时间 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： 如何获取PHP WAP自助建站系统源码？  怎样使用JSON进行数据交换_它有什么限制  Laravel观察者模式如何使用_Laravel Model Observer配置  java中使用zxing批量生成二维码立牌  在线ppt制作网站有哪些软件,如何把网页的内容做成ppt？  如何为不同团队 ID 动态生成多个“认领值班”按钮  网站建设整体流程解析，建站其实很容易！  清除minerd进程的简单方法  百度浏览器网页无法复制文字怎么办 百度浏览器复制修复  如何用AI帮你把自己的生活经历写成一个有趣的故事？  iOS发送验证码倒计时应用  Laravel软删除怎么实现_Laravel Eloquent SoftDeletes功能使用教程  香港服务器网站卡顿？如何解决网络延迟与负载问题？  Laravel数据库迁移怎么用_Laravel Migration管理数据库结构的正确姿势  创业网站制作流程,创业网站可靠吗？  Win11关机界面怎么改_Win11自定义关机画面设置【工具】  如何快速搭建个人网站并优化SEO？  昵图网官网入口 昵图网素材平台官方入口  谷歌Google入口永久地址_Google搜索引擎官网首页永久入口  海南网站制作公司有哪些,海口网是哪家的？  大连企业网站制作公司,大连2025企业社保缴费网上缴费流程？  Win11怎么设置虚拟桌面 Win11新建多桌面切换操作【技巧】  公司网站制作价格怎么算,公司办个官网需要多少钱？  猪八戒网站制作视频,开发一个猪八戒网站，大约需要多少？或者自己请程序员，需要什么程序员，多少程序员能完成？  Laravel如何实现数据导出到CSV文件_Laravel原生流式输出大数据量CSV【方案】  Javascript中的事件循环是如何工作的_如何利用Javascript事件循环优化异步代码？  使用Dockerfile构建java web环境  如何在IIS中新建站点并配置端口与物理路径？  Laravel怎么使用artisan命令缓存配置和视图  iOS验证手机号的正则表达式  如何在IIS中配置站点IP、端口及主机头？  Python自动化办公教程_ExcelWordPDF批量处理案例  如何快速搭建高效服务器建站系统？  Laravel如何部署到服务器_线上部署Laravel项目的完整流程与步骤  无锡营销型网站制作公司,无锡网选车牌流程？  手机怎么制作网站教程步骤,手机怎么做自己的网页链接？  php做exe能调用系统命令吗_执行cmd指令实现方式【详解】  利用python获取某年中每个月的第一天和最后一天  node.js报错：Cannot find module 'ejs'的解决办法  HTML5空格和margin有啥区别_空格与外边距的使用场景【说明】  Linux系统命令中tree命令详解  HTML5打空格有哪些误区_新手常犯的空格使用错误【技巧】  微信小程序 input输入框控件详解及实例（多种示例）  如何在搬瓦工VPS快速搭建网站？  Laravel如何处理表单验证？（Requests代码示例）  Laravel怎么生成URL_Laravel路由命名与URL生成函数详解  Android利用动画实现背景逐渐变暗  Windows10如何删除恢复分区_Win10 Diskpart命令强制删除分区  Laravel如何使用模型观察者？（Observer代码示例）  宙斯浏览器文件分类查看教程 快速筛选视频文档与图片方法