ScheduledExecutorService可实现Java中任务的定时与周期性调度,通过newScheduledThreadPool创建线程池,支持延迟执行、固定周期及固定延迟三种调度方式,并需调用shutdown等方法正确关闭线程池。

在Java中,线程池不仅可以用来高效地执行异步任务,还能通过特定的线程池类型实现任务的定时和周期性调度。核心工具是java.util.concurrent包中的ScheduledExecutorService接口,它扩展了ExecutorService,支持延迟执行和周期执行。
使用ScheduledExecutorService进行任务调度
ScheduledExecutorService 是管理调度任务的关键接口。通常通过 Executors 工具类创建其实例:
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(2);
这个线程池可以同时处理多个调度任务,且线程数可调,避免资源浪费。
调度任务的四种主要方式
通过 scheduler.schedule() 系列方法,可以灵活控制任务执行时机:
立即学习“Java免费学习笔记(深入)”;
请注意以下说明:1、本程序允许任何人免费使用。2、本程序采用PHP+MYSQL架构编写。并且经过ZEND加密,所以运行环境需要有ZEND引擎支持。3、需要售后服务的,请与本作者联系,联系方式见下方。4、本程序还可以与您的网站想整合,可以实现用户在线服务功能,可以让客户管理自己的信息,可以查询自己的订单状况。以及返点信息等相关客户利益的信息。这个功能可提高客户的向心度。安装方法:1、解压本系统,放在
-
延迟执行一次:使用
schedule(Runnable command, long delay, TimeUnit unit)
例如:5秒后执行一次任务scheduler.schedule(() -> System.out.println("任务执行"), 5, TimeUnit.SECONDS); -
延迟后以固定周期执行:使用
scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)
从初始延迟后开始,每隔指定时间执行一次,不管上一次任务是否完成。scheduler.scheduleAtFixedRate(() -> { System.out.println("周期任务开始"); try { Thread.sleep(2000); } catch (InterruptedException e) {} }, 1, 3, TimeUnit.SECONDS); -
延迟后以固定延迟执行:使用
scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)
上一次任务结束后,再等待指定延迟时间才执行下一次。scheduler.scheduleWithFixedDelay(() -> { System.out.println("带间隔的任务"); try { Thread.sleep(1000); } catch (InterruptedException e) {} }, 1, 2, TimeUnit.SECONDS);
正确关闭调度线程池
任务调度完成后必须显式关闭线程池,否则程序可能无法正常退出:
scheduler.shutdown();
try {
if (!scheduler.awaitTermination(60, TimeUnit.SECONDS)) {
scheduler.shutdownNow();
}
} catch (InterruptedException e) {
scheduler.shutdownNow();
Thread.currentThread().interrupt();
}
使用 shutdown() 发起关闭请求,awaitTermination() 等待任务完成,必要时调用 shutdownNow() 强制终止。
基本上就这些。合理使用 ScheduledExecutorService 可以替代老旧的 Timer 类,具备更好的健壮性和线程复用能力,适合大多数定时任务场景。









