ScheduledExecutorService详解

2024-05-14 15:28
文章标签 详解 scheduledexecutorservice

本文主要是介绍ScheduledExecutorService详解，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

文章目录

  • 基础定义
  • 主要特点
  • schedule延迟不循环
  • scheduleAtFixedRate延迟且循环
  • scheduleWithFixedDelay严格延迟且循环
  • 取消特定定时任务

基础定义

ScheduledExecutorService是Java并发包中提供的一个接口，用于执行定时任务。它继承自ExecutorService接口，并提供了额外的方法来安排和控制定时任务的执行。ScheduledExecutorService有线程池的特性，也可以实现任务循环执行，可以看作是一个简单地定时任务组件，因为有线程池特性，所以任务之间可以多线程并发执行，互不影响，当任务来的时候，才会真正创建线程去执行，我们在做一些普通定时循环任务时可以用它，比如定时刷新字典常量，只需要不断重复执行即可。

主要特点

以下是ScheduledExecutorService的一些主要特点和用法：

  • 定时任务调度：ScheduledExecutorService提供了两种方法来安排定时任务的执行：scheduleAtFixedRate和scheduleWithFixedDelay。这两种方法都可以指定任务的初始延迟时间、执行间隔以及任务的具体逻辑。

    • scheduleAtFixedRate方法按照固定的频率执行任务，即每隔指定的时间间隔执行一次。如果上一个任务的执行时间超过了设定的间隔，那么下一个任务会在上一个任务结束后立即开始执行。
    • scheduleWithFixedDelay方法也是按照固定的时间间隔执行任务，但与scheduleAtFixedRate不同的是，它会等待上一个任务完成后再开始下一个任务。

  • 任务取消：通过ScheduledExecutorService安排的任务可以通过Future对象进行取消。调用Future对象的cancel方法可以请求取消执行此任务。传递给cancel方法的参数决定了是否允许正在运行的任务正常完成。如果传递true，即使任务正在运行也会被中断；如果传递false，则允许正在运行的任务正常完成，但阻止还未开始的任务启动。

  • 线程池管理：ScheduledExecutorService是基于线程池实现的，因此它具有线程池的特性。你可以使用Executors类提供的工厂方法创建不同类型的线程池，如固定大小的线程池、缓存线程池等。

  • 资源释放：当不再需要使用ScheduledExecutorService时，应该及时关闭它以释放系统资源。可以使用shutdown或shutdownNow方法来关闭线程池。shutdown方法会等待所有已提交的任务完成后再关闭，而shutdownNow则会尝试立即停止所有正在执行的活动任务。

schedule延迟不循环

   /*** 1. 延迟不循环任务schedule方法，在固定时间点publishTime执行一次.* schedule(Runnable command, long delay, TimeUnit unit)* 参数1：任务* 参数2：方法第一次执行的延迟时间* 参数3：延迟单位* 说明：延迟任务，只执行一次(不会再次执行)，参数2为延迟时间** @param publishTime*/public static void testSchedule(LocalDateTime publishTime, UUID noticeId) {long delay = publishTime.atZone(ZoneId.systemDefault()).toInstant().toEpochMilli() - System.currentTimeMillis();ScheduledFuture scheduledFuture = executor.schedule(() -> {// 任务逻辑try {System.out.println(noticeId + ":执行任务...");} catch (Exception e) {System.out.println("定时任务执行出错..");}}, delay, TimeUnit.MILLISECONDS);taskMap.put(noticeId, scheduledFuture);executor.shutdown();}

scheduleAtFixedRate延迟且循环

/*** 2. 延迟且循环cheduleAtFixedRate方法* cheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)* 参数1：任务* 参数2：初始化完成后延迟多长时间执行第一次任务* 参数3：任务时间间隔* 参数4：单位* 方法解释：是以上一个任务开始的时间计时，比如period为5，那5秒后，检测上一个任务是否执行完毕，如果上一个任务执行完毕，则当前任务立即执行，* 如果上一个任务没有执行完毕，则需要等上一个任务执行完毕后立即执行，如果你的任务执行时间超过5秒，那么任务时间间隔参数将无效，任务会不停地循环执行，* 由此可得出该方法不能严格保证任务按一定时间间隔执行*/public static void testScheduleAtFixedRate() {executor.scheduleAtFixedRate(() -> {try {System.out.println("执行任务开始...");Thread.sleep(3000);System.out.println("执行任务结束...");} catch (Exception e) {System.out.println("定时任务执行出错..");}}, 0, 2, TimeUnit.SECONDS);}

scheduleWithFixedDelay严格延迟且循环

 /*** scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit);* 参数1：任务* 参数2：初始化完成后延迟多长时间执行第一次任务* 参数3：任务执行时间间隔* 参数4：单位* 解释：以上一次任务执行结束时间为准，加上任务时间间隔作为下一次任务开始时间，由此可以得出，任务可以严格按照时间间隔执行*/public static void testScheduleWithFixedDelay() {executor.scheduleAtFixedRate(() -> {try {System.out.println("执行任务开始...");Thread.sleep(3000);System.out.println("执行任务结束...");} catch (Exception e) {System.out.println("定时任务执行出错..");}}, 0, 2, TimeUnit.SECONDS);}

取消特定定时任务

	 /*** 记录定时任务的线程信息.*/private static final ConcurrentHashMap<UUID, ScheduledFuture> taskMap = new ConcurrentHashMap<>();/*** executor.*/private static final ScheduledExecutorService executor = Executors.newScheduledThreadPool(3);public static void main(String[] args) {// 新增UUID uuid = UUID.randomUUID();testSchedule(LocalDateTime.of(2024, 05, 14, 13, 55, 0), uuid);// 更新,可以删除上次的任务ScheduledFuture future = taskMap.get(uuid);if (Objects.nonNull(future)) {future.cancel(true);}testSchedule(LocalDateTime.of(2024, 05, 14, 11, 05, 0), UUID.randomUUID());}

这篇关于ScheduledExecutorService详解的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/989116。

相关文章

Spring Security基于数据库验证流程详解

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明（认真看哦） AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证，则会调用 #attemptAuthentica
阅读更多...
OpenHarmony鸿蒙开发（ Beta5.0）无感配网详解

OpenHarmony鸿蒙开发（ Beta5.0）无感配网详解

1、简介 无感配网是指在设备联网过程中无需输入热点相关账号信息，即可快速实现设备配网，是一种兼顾高效性、可靠性和安全性的配网方式。 2、配网原理 2.1 通信原理 手机和智能设备之间的信息传递，利用特有的NAN协议实现。利用手机和智能设备之间的WiFi 感知订阅、发布能力，实现了数字管家应用和设备之间的发现。在完成设备间的认证和响应后，即可发送相关配网数据。同时还支持与常规Sof
阅读更多...
6.1.数据结构-c/c++堆详解下篇（堆排序，TopK问题）

6.1.数据结构-c/c++堆详解下篇（堆排序，TopK问题）

上篇：6.1.数据结构-c/c++模拟实现堆上篇（向下，上调整算法，建堆，增删数据）-CSDN博客 本章重点 1.使用堆来完成堆排序 2.使用堆解决TopK问题 目录 一.堆排序 1.1 思路 1.2 代码 1.3 简单测试 二.TopK问题 2.1 思路(求最小)： 2.2 C语言代码（手写堆） 2.3 C++代码（使用优先级队列 priority_queue）
阅读更多...
K8S（Kubernetes）开源的容器编排平台安装步骤详解

K8S（Kubernetes）开源的容器编排平台安装步骤详解

K8S（Kubernetes）是一个开源的容器编排平台，用于自动化部署、扩展和管理容器化应用程序。以下是K8S容器编排平台的安装步骤、使用方式及特点的概述： 安装步骤： 安装Docker：K8S需要基于Docker来运行容器化应用程序。首先要在所有节点上安装Docker引擎。 安装Kubernetes Master：在集群中选择一台主机作为Master节点，安装K8S的控制平面组件，如AP
阅读更多...
嵌入式Openharmony系统构建与启动详解

嵌入式Openharmony系统构建与启动详解

大家好，今天主要给大家分享一下，如何构建Openharmony子系统以及系统的启动过程分解。 第一：OpenHarmony系统构建      首先熟悉一下，构建系统是一种自动化处理工具的集合，通过将源代码文件进行一系列处理，最终生成和用户可以使用的目标文件。这里的目标文件包括静态链接库文件、动态链接库文件、可执行文件、脚本文件、配置文件等。      我们在编写hellowor
阅读更多...
LabVIEW FIFO详解

LabVIEW FIFO详解

在LabVIEW的FPGA开发中，FIFO（先入先出队列）是常用的数据传输机制。通过配置FIFO的属性，工程师可以在FPGA和主机之间，或不同FPGA VIs之间进行高效的数据传输。根据具体需求，FIFO有多种类型与实现方式，包括目标范围内FIFO（Target-Scoped）、DMA FIFO以及点对点流（Peer-to-Peer）。 FIFO类型 **目标范围FIFO（Target-Sc
阅读更多...
019、JOptionPane类的常用静态方法详解

019、JOptionPane类的常用静态方法详解

目录 JOptionPane类的常用静态方法详解 1. showInputDialog()方法 1.1基本用法 1.2带有默认值的输入框 1.3带有选项的输入对话框 1.4自定义图标的输入对话框 2. showConfirmDialog()方法 2.1基本用法 2.2自定义按钮和图标 2.3带有自定义组件的确认对话框 3. showMessageDialog()方法 3.1
阅读更多...
脏页的标记方式详解

脏页的标记方式详解

脏页的标记方式 一、引言 在数据库系统中，脏页是指那些被修改过但还未写入磁盘的数据页。为了有效地管理这些脏页并确保数据的一致性，数据库需要对脏页进行标记。了解脏页的标记方式对于理解数据库的内部工作机制和优化性能至关重要。 二、脏页产生的过程 当数据库中的数据被修改时，这些修改首先会在内存中的缓冲池（Buffer Pool）中进行。例如，执行一条 UPDATE 语句修改了某一行数据，对应的缓
阅读更多...
OmniGlue论文详解（特征匹配）

OmniGlue论文详解（特征匹配）

OmniGlue论文详解（特征匹配） 摘要1. 引言2. 相关工作2.1. 广义局部特征匹配2.2. 稀疏可学习匹配2.3. 半稠密可学习匹配2.4. 与其他图像表示匹配 3. OmniGlue3.1. 模型概述3.2. OmniGlue 细节3.2.1. 特征提取3.2.2. 利用DINOv2构建图形。3.2.3. 信息传播与新的指导3.2.4. 匹配层和损失函数3.2.5. 与Super
阅读更多...
web群集--nginx配置文件location匹配符的优先级顺序详解及验证

web群集--nginx配置文件location匹配符的优先级顺序详解及验证

文章目录 前言优先级顺序优先级顺序(详解)1. 精确匹配（Exact Match）2. 正则表达式匹配（Regex Match）3. 前缀匹配（Prefix Match） 匹配规则的综合应用验证优先级 前言 location的作用 在 NGINX 中，location 指令用于定义如何处理特定的请求 URI。由于网站往往需要不同的处理方式来适应各种请求，NGINX 提供了多种匹
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2