聊聊高并发(三十八)解析java.util.concurrent各个组件(十四) 理解Executor接口的设计

简介:

JUC包中除了一系列的同步类之外,就是Executor运行框架相关的类。对于一个运行框架来说,能够分为两部分

1. 任务的提交

2. 任务的运行。

这是一个生产者消费者模式,提交任务的操作是生产者,运行任务的线程相当于消费者。


Executor接口设计的目的是专注于任务的运行。和任务的提交解耦。

任务的提交由任务的创建者处理。

Executor接口封装了任务运行的细节,比方怎样使用线程,是否定时运行等等。

Executor接口非常easy,就一个execute方法。

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

假设不使用Executor接口,直接用Thread显式地来运行一个Runnable。代码是这种

new Thread(new RunnableTask()).start()

而使用Executor接口运行Runnable的代码是这种

Executor executor = xxxExecutor;
executor.execute(new RunnableTask());

能够看到Executor接口的一个是屏蔽了任务运行的细节。

它全然能够直接使用Executor所在的线程直接同步运行任务

class DirectExecutor implements Executor {
    public void execute(Runnable r) {
       r.run();
    }
}

也能够使用单独的线程来运行任务,从而异步的运行任务。

class ThreadPerTaskExecutor implements Executor {
   public void execute(Runnable r) {
        new Thread(r).start();
     }
}

《Java并发编程实战》一书中将任务运行的细节称为运行策略。运行策略定义了任务运行的What, Where, When, How

1. 在什么(What)线程中运行任务?

2. 任务依照什么(What)顺序运行(FIFO,LIFO,优先级)

3. 有多少个(How Many)任务能并发运行

4. 在队列中有(How Many)任务在等待运行

5. 假设系统因为过载Overload而须要拒绝一个任务。那么应该选择哪一个(Which)任务?怎样(How)通知应用程序有任务被拒绝

6. 在运行一个任务之前或之后,应该进行哪些(What)动作?


这几点都是设计一个运行框架须要考虑的事情。比方ThreadPoolExecutor攻克了线程池的问题,ExecutorService攻克了运行任务生命周期管理的问题。ScheduleExecutorService攻克了定时运行任务的问题。


以下这个在Executor JavaDoc里的串行运行任务的Exector,能够看到怎样扩展Executor来自己定义运行的策略。

1. 封装了一个ArrayDeque队列来存放待运行的Runnable任务

2. 真正用来运行任务的Executor对象

3. 当前要运行的任务active对象

4. SerialExecutor的execute方法先讲传入的Runnable任务再封装一层,增加到tasks队列,保证这个任务运行完后会去调用scheduleNext()运行下一个任务。然后推断active对象是否是null,表示是第一次运行。就显式地运行scheduleNext().

5. scheduleNext()方法从队列中取任务运行

6. execute()和scheduleNext()都是synchronized方法。保证串行运行。


 class SerialExecutor implements Executor {
    final Queue<Runnable> tasks = new ArrayDeque<Runnable>();
    final Executor executor;
    Runnable active;
 
    SerialExecutor(Executor executor) {
      this.executor = executor;
    }
 
    public synchronized void execute(final Runnable r) {
      tasks.offer(new Runnable() {
        public void run() {
          try {
            r.run();
          } finally {
            scheduleNext();
          }
        }
      });
      if (active == null) {
        scheduleNext();
      }
    }
 
    protected synchronized void scheduleNext() {
      if ((active = tasks.poll()) != null) {
        executor.execute(active);
      }
    }
  }}







本文转自mfrbuaa博客园博客,原文链接:http://www.cnblogs.com/mfrbuaa/p/5082200.html,如需转载请自行联系原作者

相关文章
|
9月前
|
Java 数据安全/隐私保护 索引
(Java)Java里JFrame窗体的基本操作(组件篇-3)
回顾 说过了下拉框和下拉列表,本篇内容将了解滚动面板和各类输入框 什么是组件? 如果不熟悉组件,可以将组件看作是某个Form表单中的表单元素,组件可以完善JFrame窗口的布局,以及一些功能; 本篇内容中所有的组件所用到的类全都来自于javax.swing这个包中,记得引入; 另:在使用组件前,请先将窗体中的内容类给实例化出来进行操作,代码如下: Container c = getContentPane(); JScollPane JScollPane类,说的就是滚动面板。它不同于其他组件,它是一个容器,
198 2
|
9月前
|
Java 索引 容器
(Java)Java里JFrame窗体的基本操作(组件篇-2)
回顾 这算是JFrame窗体基本操作的组件第二篇了,上一篇说过了单选框,复选框,按钮。 在这一篇中,我会说明下拉框和列表框 什么是组件? 自行百度:java中JFrame窗体里的组件是什么? 名字都给你想好了 ( :I ) JComBox下拉框 JComBox类,就是下拉框,实例化出来后,要填写泛型&lt;&gt;,添加是什么数据类型的内容,泛型中就写上该数据类型; JComboBox&lt;?&gt; combox = new JComboBox&lt;&gt;(); 以下实例化下拉框的时候我泛型写的全
242 1
|
9月前
|
Java 容器
(Java)Java里JFrame窗体的基础操作(组件-1)
如果不熟悉组件,可以将组件看作是某个Form表单中的表单元素,当然这只是在不熟悉组件的前提下。如果深入了解了组件,那么它有着非常多的组件,这些组件可以完善JFrame窗口的布局,以及一些功能; 本篇内容中所有的组件所用到的类全都来自于javax.swing这个包中,记得引入
198 1
|
10月前
|
机器学习/深度学习 JSON Java
Java调用Python的5种实用方案:从简单到进阶的全场景解析
在机器学习与大数据融合背景下,Java与Python协同开发成为企业常见需求。本文通过真实案例解析5种主流调用方案,涵盖脚本调用到微服务架构,助力开发者根据业务场景选择最优方案,提升开发效率与系统性能。
2195 0
|
10月前
|
Java
Java的CAS机制深度解析
CAS(Compare-And-Swap)是并发编程中的原子操作,用于实现多线程环境下的无锁数据同步。它通过比较内存值与预期值,决定是否更新值,从而避免锁的使用。CAS广泛应用于Java的原子类和并发包中,如AtomicInteger和ConcurrentHashMap,提升了并发性能。尽管CAS具有高性能、无死锁等优点,但也存在ABA问题、循环开销大及仅支持单变量原子操作等缺点。合理使用CAS,结合实际场景选择同步机制,能有效提升程序性能。
|
10月前
|
Java 开发者
Java并发编程:CountDownLatch实战解析
Java并发编程:CountDownLatch实战解析
634 100
|
11月前
|
数据采集 JSON Java
Java爬虫获取1688店铺所有商品接口数据实战指南
本文介绍如何使用Java爬虫技术高效获取1688店铺商品信息,涵盖环境搭建、API调用、签名生成及数据抓取全流程,并附完整代码示例,助力市场分析与选品决策。
|
9月前
|
存储 安全 Java
《数据之美》:Java集合框架全景解析
Java集合框架是数据管理的核心工具,涵盖List、Set、Map等体系,提供丰富接口与实现类,支持高效的数据操作与算法处理。
|
10月前
|
算法 安全 Java
除了类,Java中的接口和方法也可以使用泛型吗?
除了类,Java中的接口和方法也可以使用泛型吗?
283 11
|
9月前
|
Java Go 开发工具
【Java】(9)抽象类、接口、内部的运用与作用分析,枚举类型的使用
抽象类必须使用abstract修饰符来修饰,抽象方法也必须使用abstract修饰符来修饰,抽象方法不能有方法体。抽象类不能被实例化,无法使用new关键字来调用抽象类的构造器创建抽象类的实例。抽象类可以包含成员变量、方法(普通方法和抽象方法都可以)、构造器、初始化块、内部类(接 口、枚举)5种成分。抽象类的构造器不能用于创建实例,主要是用于被其子类调用。抽象类中不一定包含抽象方法,但是有抽象方法的类必定是抽象类abstract static不能同时修饰一个方法。
361 1

推荐镜像

更多
  • DNS