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());}