任务调度新境界：探秘ScheduledExecutorService的异步魔力

欢迎来到我的博客，代码的世界里，每一行都是一个故事


在这里插入图片描述

任务调度新境界：探秘ScheduledExecutorService的异步魔力

    • 前言
    • ScheduledExecutorService的基本概念
      • 基本概念：
      • 为何它是 Java 中任务调度的首选工具：
      • 基本用法：
    • ScheduledExecutorService的创建与配置
      • 配置项：
    • 任务的添加与取消
      • 添加定时任务：
      • 取消定时任务：
    • 不同类型的定时任务
      • 定时执行任务：
      • 固定频率执行任务：
      • 固定延迟执行任务：
    • 异常处理与容错机制
      • 1. 异常处理：
      • 2. 使用 UncaughtExceptionHandler：
      • 3. 封装任务逻辑：
      • 4. 返回 Future 对象：
      • 5. 合理的重试机制：
      • 注意事项：
    • ScheduledExecutorService的优势与劣势
      • 优势：
      • 局限性与风险：

前言

在编程的世界里，我们经常需要让某些任务在未来的特定时间点执行。这就是ScheduledExecutorService登场的时刻，它是一个任务调度的专业管家，能够精确地掌握时间的舞步。让我们一同踏入这个时间的王国，探索其中的奇妙之处。

ScheduledExecutorService的基本概念

ScheduledExecutorService 是 Java 并发包提供的接口，用于支持任务的调度和执行。它是一个更强大、更灵活的定时任务调度工具，相较于传统的 Timer 类，ScheduledExecutorService 具有更多的功能和更好的性能。

基本概念：

  1. 定义： ScheduledExecutorService 接口是 ExecutorService 的子接口，用于在给定的时间延迟之后，或者周期性地执行任务。

  2. 基本原理： ScheduledExecutorService 使用线程池来管理和执行任务，可以异步地执行任务，支持延迟执行和周期性执行。

为何它是 Java 中任务调度的首选工具：

  1. 灵活性： ScheduledExecutorService 提供了更灵活的任务调度机制，可以支持延迟执行、周期性执行等多种调度方式。这使得它适用于各种不同的定时任务场景。

  2. 可控性： 通过使用线程池，ScheduledExecutorService 提供了对任务执行线程的管理和控制，能够更好地适应不同的并发需求。

  3. 异常处理： 与 Timer 不同，ScheduledExecutorService 对于任务执行中的异常有更好的处理机制，不会因为一个任务的异常导致整个调度器终止。

  4. 相对线程安全： ScheduledExecutorService 在设计上相对于 Timer 更加线程安全，更适合在多线程环境中使用。

  5. 替代 Timer： 由于 ScheduledExecutorService 具有更多功能且更健壮，它通常被认为是 Timer 的替代品，特别是在需要更复杂调度需求和更好性能的情况下。

  6. ExecutorService 的扩展： 作为 ExecutorService 的子接口，ScheduledExecutorService 不仅可以执行定时任务，还能执行普通的异步任务，使得任务的管理更加一致和统一。

基本用法：

使用 ScheduledExecutorService 的基本流程如下：

  1. 创建 ScheduledExecutorService 实例：

    ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);

  2. 创建任务（实现 Runnable 或 Callable 接口）：

    Runnable task = () -> {// 任务逻辑System.out.println("Task executed at: " + System.currentTimeMillis());
};

  3. 安排任务的执行：

    • 在延迟一定时间后执行任务：

      scheduledExecutorService.schedule(task, 1, TimeUnit.SECONDS); // 1秒后执行

    • 周期性执行任务：

      scheduledExecutorService.scheduleAtFixedRate(task, 0, 2, TimeUnit.SECONDS); // 每2秒执行一次

  4. 关闭 ScheduledExecutorService：

    scheduledExecutorService.shutdown();

总体而言，ScheduledExecutorService 提供了更灵活和强大的任务调度功能，是 Java 中任务调度的首选工具之一。

ScheduledExecutorService的创建与配置

ScheduledExecutorService 的创建和配置通常通过 Executors 工厂类完成。下面是一个基本的实例化和配置 ScheduledExecutorService 的例子：

import java.util.concurrent.*;public class ScheduledExecutorServiceExample {public static void main(String[] args) {// 创建一个具有固定线程数的 ScheduledExecutorServiceScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(3);// 创建任务Runnable task = () -> {// 任务逻辑System.out.println("Task executed at: " + System.currentTimeMillis());};// 配置任务的执行方式ScheduledFuture<?> scheduledFuture = scheduledExecutorService.scheduleAtFixedRate(task,    // 任务0,       // 初始延迟2,       // 间隔时间TimeUnit.SECONDS  // 时间单位);// 关闭 ScheduledExecutorServicescheduledExecutorService.shutdown();}
}

在上述例子中，我们通过 Executors.newScheduledThreadPool(3) 创建了一个固定线程数为 3 的 ScheduledExecutorService。接着，我们定义了一个简单的任务 task，并使用 scheduleAtFixedRate 方法配置了任务的执行方式。最后，我们通过 shutdown 方法关闭了 ScheduledExecutorService。

配置项：

newScheduledThreadPool 方法允许你传递一个整数参数，用于指定线程池的大小。这个参数表示同时执行的线程数，也即池中的最大线程数。除了这个参数外，newScheduledThreadPool 方法还允许你传递一个 ThreadFactory 对象，用于创建线程。

对于更高级的配置，可以使用 ScheduledThreadPoolExecutor 的构造函数，允许你手动配置线程池的各种参数，如核心线程数、最大线程数、线程空闲时间等。

ScheduledExecutorService scheduledExecutorService = new ScheduledThreadPoolExecutor(corePoolSize,      // 核心线程数threadFactory,      // 线程工厂handler             // 拒绝策略
);

其中，corePoolSize 是核心线程数，threadFactory 是线程工厂，handler 是拒绝策略。这样的创建方式更为灵活，可以根据实际需求进行配置。

任务的添加与取消

在 ScheduledExecutorService 中，可以使用不同的方法来添加和取消定时任务。以下是添加和取消定时任务的基本方法：

添加定时任务：

  1. 使用 schedule 方法：

    ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);Runnable task = () -> {// 任务逻辑System.out.println("Task executed at: " + System.currentTimeMillis());
};// 在延迟一定时间后执行任务
ScheduledFuture<?> scheduledFuture = scheduledExecutorService.schedule(task, 1, TimeUnit.SECONDS);// 关闭 ScheduledExecutorService
scheduledExecutorService.shutdown();

  2. 使用 scheduleAtFixedRate 或 scheduleWithFixedDelay 方法：

    ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);Runnable task = () -> {// 任务逻辑System.out.println("Task executed at: " + System.currentTimeMillis());
};// 周期性执行任务，scheduleAtFixedRate 方法
// 或者使用 scheduleWithFixedDelay 方法// 关闭 ScheduledExecutorService
scheduledExecutorService.shutdown();

取消定时任务：

  1. 使用 ScheduledFuture 对象取消任务：

    ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);Runnable task = () -> {// 任务逻辑System.out.println("Task executed at: " + System.currentTimeMillis());
};// 在延迟一定时间后执行任务
ScheduledFuture<?> scheduledFuture = scheduledExecutorService.schedule(task, 1, TimeUnit.SECONDS);// 取消任务
boolean cancelled = scheduledFuture.cancel();// 关闭 ScheduledExecutorService
scheduledExecutorService.shutdown();

    cancel 方法返回一个布尔值，表示任务是否被取消成功。如果任务已经开始执行或已经完成，取消操作将失败。

  2. 使用 shutdownNow 方法取消所有任务：

    ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);Runnable task = () -> {// 任务逻辑System.out.println("Task executed at: " + System.currentTimeMillis());
};// 在延迟一定时间后执行任务
ScheduledFuture<?> scheduledFuture = scheduledExecutorService.schedule(task, 1, TimeUnit.SECONDS);// 取消所有任务
List<Runnable> cancelledTasks = scheduledExecutorService.shutdownNow();// 关闭 ScheduledExecutorService
scheduledExecutorService.shutdown();

    shutdownNow 方法返回一个 List<Runnable>，包含所有被取消的任务。

注意事项：

  • 使用 cancel 方法时，需要注意任务是否已经开始执行或已经完成。取消操作只在任务尚未开始执行时才能成功。
  • 在使用 shutdownNow 方法取消所有任务时，可能会中断正在执行的任务。因此，需要确保任务的设计和实现能够处理中断。

不同类型的定时任务

在 ScheduledExecutorService 中，有多种方法可以配置不同类型的定时任务，包括定时执行任务、固定频率执行任务等。以下是不同类型的定时任务以及使用不同的方法配置的示例：

定时执行任务：

ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);Runnable task = () -> {// 任务逻辑System.out.println("Task executed at: " + System.currentTimeMillis());
};// 在延迟一定时间后执行任务
ScheduledFuture<?> scheduledFuture = scheduledExecutorService.schedule(task, 1, TimeUnit.SECONDS);// 关闭 ScheduledExecutorService
scheduledExecutorService.shutdown();

上述代码中，schedule 方法用于在延迟一定时间后执行任务，即定时执行任务。

固定频率执行任务：

ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);Runnable task = () -> {// 任务逻辑System.out.println("Task executed at: " + System.currentTimeMillis());
};// 周期性执行任务，scheduleAtFixedRate 方法
ScheduledFuture<?> scheduledFuture = scheduledExecutorService.scheduleAtFixedRate(task,    // 任务0,       // 初始延迟2,       // 间隔时间TimeUnit.SECONDS  // 时间单位
);// 关闭 ScheduledExecutorService
scheduledExecutorService.shutdown();

上述代码中，scheduleAtFixedRate 方法用于周期性地执行任务，可以指定初始延迟和执行间隔。

固定延迟执行任务：

ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);Runnable task = () -> {// 任务逻辑System.out.println("Task executed at: " + System.currentTimeMillis());
};// 固定延迟执行任务，scheduleWithFixedDelay 方法
ScheduledFuture<?> scheduledFuture = scheduledExecutorService.scheduleWithFixedDelay(task,    // 任务0,       // 初始延迟2,       // 间隔时间TimeUnit.SECONDS  // 时间单位
);// 关闭 ScheduledExecutorService
scheduledExecutorService.shutdown();

上述代码中，scheduleWithFixedDelay 方法用于固定延迟地执行任务，即任务执行完毕后等待指定的时间再执行下一次。

注意事项：

  • 定时任务的配置方法根据具体需求选择。schedule 适用于延迟一定时间后执行一次的任务，scheduleAtFixedRate 适用于周期性执行任务，而 scheduleWithFixedDelay 适用于固定延迟执行任务。
  • 在使用这些方法时，需要考虑任务的执行时间和任务之间的依赖关系，以确保任务能够按照预期执行。

异常处理与容错机制

在 ScheduledExecutorService 中，处理任务执行中的异常是关键的一部分，以确保定时任务的稳定性。以下是一些处理异常和容错机制的方法：

1. 异常处理：

在任务的 run 方法中进行异常处理是一种常见的做法，可以使用 try-catch 块捕获异常，并在异常发生时执行适当的处理逻辑。例如，记录日志、发送警报或执行备用逻辑。

Runnable task = () -> {try {// 任务逻辑// ...} catch (Exception e) {// 异常处理逻辑// 记录日志、发送警报等e.printStackTrace();}
};

2. 使用 UncaughtExceptionHandler：

ScheduledThreadPoolExecutor 类提供了 setUncaughtExceptionHandler 方法，可以设置一个全局的未捕获异常处理器。这个处理器将在任务抛出未捕获的异常时被调用。

Thread.UncaughtExceptionHandler exceptionHandler = (thread, throwable) -> {// 全局未捕获异常处理逻辑// 记录日志、发送警报等throwable.printStackTrace();
};ScheduledExecutorService scheduledExecutorService = new ScheduledThreadPoolExecutor(1);
((ScheduledThreadPoolExecutor) scheduledExecutorService).setUncaughtExceptionHandler(exceptionHandler);Runnable task = () -> {// 任务逻辑// ...
};

3. 封装任务逻辑：

将任务逻辑封装在一个方法中，并在方法内进行异常处理。这样可以使任务逻辑更加清晰，异常处理也更为集中。

Runnable task = () -> {try {// 封装的任务逻辑executeTask();} catch (Exception e) {// 异常处理逻辑// 记录日志、发送警报等e.printStackTrace();}
};private void executeTask() {// 具体的任务逻辑// ...
}

4. 返回 Future 对象：

ScheduledExecutorService 的 schedule 方法返回一个 ScheduledFuture 对象，可以使用这个对象检查任务的执行状态和获取任务的执行结果。通过检查 ScheduledFuture 对象，可以在任务执行失败时获取异常信息。

ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);Runnable task = () -> {// 任务逻辑// ...
};ScheduledFuture<?> scheduledFuture = scheduledExecutorService.schedule(task, 1, TimeUnit.SECONDS);try {// 获取任务执行结果，这里会抛出异常，可以在这里处理异常scheduledFuture.get();
} catch (Exception e) {// 异常处理逻辑// 记录日志、发送警报等e.printStackTrace();
}// 关闭 ScheduledExecutorService
scheduledExecutorService.shutdown();

5. 合理的重试机制：

在异常发生时，可以考虑使用重试机制，即在一定次数内尝试重新执行任务。这可以通过在任务逻辑中使用循环来实现。

Runnable task = () -> {int maxAttempts = 3;for (int attempt = 1; attempt <= maxAttempts; attempt++) {try {// 任务逻辑// ...break; // 任务成功执行，跳出循环} catch (Exception e) {// 异常处理逻辑// 记录日志、发送警报等e.printStackTrace();if (attempt < maxAttempts) {// 等待一段时间后重试Thread.sleep(1000);} else {// 达到最大重试次数，放弃任务执行break;}}}
};

注意事项：

  • 在异常处理中，需要根据具体业务需求选择合适的处理方式，例如记录日志、发送警报、重试等。
  • 在定时任务中，为了确保任务执行的稳定性，合理的异常处理和容错机制是至关重要的。

ScheduledExecutorService的优势与劣势

优势：

  1. 灵活性： ScheduledExecutorService 提供了更灵活的任务调度机制，支持延迟执行、周期性执行等多种调度方式。这使得它适用于各种不同的定时任务场景。

  2. 可控性： 通过使用线程池，ScheduledExecutorService 提供了对任务执行线程的管理和控制，能够更好地适应不同的并发需求。

  3. 异常处理： 相对于 Timer，ScheduledExecutorService 对于任务执行中的异常有更好的处理机制，不会因为一个任务的异常导致整个调度器终止。

  4. 相对线程安全： ScheduledExecutorService 在设计上相对于 Timer 更加线程安全，更适合在多线程环境中使用。

  5. ExecutorService 的扩展： 作为 ExecutorService 的子接口，ScheduledExecutorService 不仅可以执行定时任务，还能执行普通的异步任务，使得任务的管理更加一致和统一。

  6. 更好的性能： 相较于 Timer，ScheduledExecutorService 的性能通常更好。它能够更好地处理任务的并发执行，提高系统的吞吐量。

局限性与风险：

  1. 不适用于复杂场景： 对于一些复杂的任务调度场景，例如需要更高级的调度策略、任务间的依赖关系等，ScheduledExecutorService 可能显得力不从心，因为其功能相对有限。

  2. 定时器线程生命周期管理： ScheduledExecutorService 的定时器线程在 shutdown 方法被调用后不会被及时终止，可能导致应用程序无法正常退出。需要谨慎管理定时器线程的生命周期。

  3. 不支持任务的取消和修改： 一旦定时任务被安排，就不能取消或修改其执行时间，只能取消整个定时器并重新创建。

  4. 任务执行时间长： 如果某个任务的执行时间过长，可能会影响后续任务的调度，因为任务是按照顺序执行的。

总体而言，ScheduledExecutorService 是一个更灵活、更可控且相对线程安全的定时任务调度工具，适用于大多数场景。然而，在一些复杂的调度需求下，可能需要考虑使用其他更为高级的调度工具或框架。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/519134.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

MySQL-查询SQL语句的执行过程：连接器-＞查询缓存(8就没了)-＞分析器-＞优化器-＞执行器-＞返回结果

MySQL-查询SQL语句的执行过程：连接器-＞查询缓存(8就没了)-＞分析器-＞优化器-＞执行器-＞返回结果

MySQL-查询SQL语句的执行过程&#xff1a;连接器->查询缓存<8就没了>->分析器->优化器->执行器->返回结果 查询SQL语句的执行过程1、主要步骤2、实用案例 查询SQL语句的执行过程 1、主要步骤 在MySQL中&#xff0c;一条查询SQL语句的执行过程非常复杂且…
阅读更多...
day14_异常

day14_异常

今日内容 零、 复习昨日 一、日期类 二、异常 零、 复习昨日 1为什么要重写toString Object类toString返回的是对象名字地址,无意义子类重写toString() 返回的对象属性内容 2为什么要重写equals Object类equals判断是对象的地址值是否相等,无意义子类重写equals,为了判断对象的…
阅读更多...
如何写一份简单的产品说明书，教程奉上

如何写一份简单的产品说明书，教程奉上

如果你是一位新晋产品经理&#xff0c;或者正在研发新产品&#xff0c;并且心中惴惴不安因为未知的产品说明书制作环节&#xff0c;那么今天你就来对地方了。本篇文章将教你如何创建一份简单明了的产品说明书。让我们开始吧&#xff01; 首先&#xff0c;明确产品说明书的目标。…
阅读更多...
Leetcoder Day42｜ 动态规划part09 打家劫舍问题

Leetcoder Day42｜ 动态规划part09 打家劫舍问题

198.打家劫舍 你是一个专业的小偷&#xff0c;计划偷窃沿街的房屋。每间房内都藏有一定的现金&#xff0c;影响你偷窃的唯一制约因素就是相邻的房屋装有相互连通的防盗系统&#xff0c;如果两间相邻的房屋在同一晚上被小偷闯入&#xff0c;系统会自动报警。 给定一个代表每个房…
阅读更多...
从新手到大师：顶级PPT学习网站推荐，让你的幻灯片脱颖而出！

从新手到大师：顶级PPT学习网站推荐，让你的幻灯片脱颖而出！

介绍&#xff1a;PowerPoint&#xff0c;简称PPT&#xff0c;是微软公司开发的一款演示程序&#xff0c;也是Microsoft Office套件的重要组成部分之一。 PPT允许用户通过幻灯片的形式创建和展示信息&#xff0c;这些幻灯片可以包含文本、图形、图表、视频、音频等多种元素。用户…
阅读更多...
Linux-网络-011

Linux-网络-011

1网络协议模型 1.1【OSI】协议模型 1.1.1应用层 实际发送的数据应用层:HTTP 超文本传输协议HTTPS FTP 文件传输协议TFTP 简单文本传输协议SMTP 邮件传输协议MQTT TELNET ..1.1.2表示层 发送的数据是否加密1.1.3会话层 是否建立会话连接1.1.4传输层 数据…
阅读更多...
解决 Chrome 无法代理外网，但Safari等其他软件可以

解决 Chrome 无法代理外网，但Safari等其他软件可以

文章目录 1. 问题2. 解决方法 1. 问题 开启代理之后&#xff0c;Chrome 浏览器仍然无法访问外网。但是用 Mac 的 Safari 浏览器或者其他的软件已经可以访问外网。 2. 解决方法 发现 Chrome 浏览器的某些拓展程序会影响代理&#xff0c;可以关闭 Chrome 的拓展程序试试&#…
阅读更多...
二维码门楼牌管理系统应用场景：数据管理的智慧新选择

二维码门楼牌管理系统应用场景：数据管理的智慧新选择

文章目录 前言一、数据管理部门的智慧工具二、助力决策制定与优质服务提供三、二维码门楼牌管理系统的优势四、展望未来 前言 随着科技的飞速发展&#xff0c;二维码门楼牌管理系统正逐渐成为城市管理的智慧新选择。该系统不仅提升了数据管理效率&#xff0c;还为政府和企业提…
阅读更多...
软件系统开发安全指南-word

软件系统开发安全指南-word

应用系统设计安全主要涵盖以下几点&#xff1a; 1、应用系统架构安全设计 2、应用系统软件功能安全设计 3、应用系统存储安全设计 4、应用系统通讯安全设计 5、应用系统数据库安全设计 应用系统测试安全包含&#xff1a; 1、测试前置要求 2、测试方法及测试内容 3、测试环境及人…
阅读更多...
idea Gradle 控制台中文乱码

idea Gradle 控制台中文乱码

如下图所示&#xff0c;idea 中的 Gradle 控制台中文乱码&#xff1a; 解决方法&#xff0c;如下图所示&#xff1a; 注意&#xff1a;如果你的 idea 使用 crack 等方式破解了&#xff0c;那么你可能需要在文件 crack-2023\jetbra\vmoptions\idea.vmoptions 中进行配置&#xf…
阅读更多...
Linux 开发工具 yum、git、gdb

Linux 开发工具 yum、git、gdb

目录 一、yum 1、软件包 2、rzsz 3、注意事项 4、查看软件包 5、安装软件 6、卸载软件 二、git操作 1、克隆三板斧 2、第一次使用会出现以下情况&#xff1a; 未配置用户名和邮箱&#xff1a; push后弹出提示 三、gdb使用 1、背景 2、使用方法 例一&#xff1a…
阅读更多...
谷歌seo外链怎么发？

谷歌seo外链怎么发？

谷歌SEO外链建设&#xff0c;说白了&#xff0c;就是让别的网站放一条或几条链接指向你的网站&#xff0c;这事听着简单&#xff0c;但你凭什么在别人的地盘放自己网站的链接&#xff0c;就算真的能放自己网站的链接&#xff0c;你又是否能保证你发的内容跟自己网站相关&#x…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023