聊聊高并发(三十八)解析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,如需转载请自行联系原作者

相关文章
|
1月前
|
消息中间件 Java Kafka
Java 事件驱动架构设计实战与 Kafka 生态系统组件实操全流程指南
本指南详解Java事件驱动架构与Kafka生态实操,涵盖环境搭建、事件模型定义、生产者与消费者实现、事件测试及高级特性,助你快速构建高可扩展分布式系统。
133 7
|
2月前
|
人工智能 Cloud Native Java
2025 年 Java 应届生斩获高薪需掌握的技术实操指南与实战要点解析
本指南为2025年Java应届生打造,涵盖JVM调优、响应式编程、云原生、微服务、实时计算与AI部署等前沿技术,结合电商、数据处理等真实场景,提供可落地的技术实操方案,助力掌握高薪开发技能。
135 2
|
1月前
|
缓存 安全 Java
Java并发性能优化|读写锁与互斥锁解析
本文深入解析Java中两种核心锁机制——互斥锁与读写锁,通过概念对比、代码示例及性能测试,揭示其适用场景。互斥锁适用于写多或强一致性场景,读写锁则在读多写少时显著提升并发性能。结合锁降级、公平模式等高级特性,助你编写高效稳定的并发程序。
86 0
|
2月前
|
人工智能 Java 程序员
搭建AI智能体的Java神器:Google ADK深度解析
想用Java构建复杂的AI智能体?Google开源的ADK工具包来了!代码优先、模块化设计,让你像搭积木一样轻松组合智能体。从单体到多智能体系统,从简单工具到复杂编排,这篇文章带你玩转Java AI开发的全新境界。
|
2月前
|
安全 算法 Java
Java 多线程:线程安全与同步控制的深度解析
本文介绍了 Java 多线程开发的关键技术,涵盖线程的创建与启动、线程安全问题及其解决方案,包括 synchronized 关键字、原子类和线程间通信机制。通过示例代码讲解了多线程编程中的常见问题与优化方法,帮助开发者提升程序性能与稳定性。
117 0
|
1月前
|
安全 Oracle Java
JAVA高级开发必备·卓伊凡详细JDK、JRE、JVM与Java生态深度解析-形象比喻系统理解-优雅草卓伊凡
JAVA高级开发必备·卓伊凡详细JDK、JRE、JVM与Java生态深度解析-形象比喻系统理解-优雅草卓伊凡
147 0
JAVA高级开发必备·卓伊凡详细JDK、JRE、JVM与Java生态深度解析-形象比喻系统理解-优雅草卓伊凡
|
23天前
|
算法 Java 测试技术
零基础学 Java: 从语法入门到企业级项目实战的详细学习路线解析
本文为零基础学习者提供完整的Java学习路线,涵盖语法基础、面向对象编程、数据结构与算法、多线程、JVM原理、Spring框架、Spring Boot及项目实战,助你从入门到进阶,系统掌握Java编程技能,提升实战开发能力。
71 0
|
2月前
|
存储 Java Linux
操作系统层面视角下 Java IO 的演进路径及核心技术变革解析
本文从操作系统层面深入解析Java IO的演进历程,涵盖BIO、NIO、多路复用器及Netty等核心技术。分析各阶段IO模型的原理、优缺点及系统调用机制,探讨Java如何通过底层优化提升并发性能与数据处理效率,全面呈现IO技术的变革路径与发展趋势。
48 1
|
2月前
|
并行计算 Java API
Java List 集合结合 Java 17 新特性与现代开发实践的深度解析及实战指南 Java List 集合
本文深入解析Java 17中List集合的现代用法,结合函数式编程、Stream API、密封类、模式匹配等新特性,通过实操案例讲解数据处理、并行计算、响应式编程等场景下的高级应用,帮助开发者提升集合操作效率与代码质量。
124 1

热门文章

最新文章

推荐镜像

更多
  • DNS