Java ScheduledExecutorService的具体使用
ScheduledExecutorService有线程池的特性，也可以实现任务循环执行，可以看作是一个简单地定时任务组件，因为有线程池特性，所以任务之间可以多线程并发执行，互不影响，当任务来的时候，才会真正创建线程去执行
我们在做一些普通定时循环任务时可以用它，比如定时刷新字典常量，只需要不断重复执行即可，这篇文章讲解一下它的用法以及注意事项，不涉及底层原理
注意：我们都知道，在使用线程池的时候，如果我们的任务出现异常没有捕获，那么线程会销毁被回收，不会影响其他任务继续提交并执行，但是在这里，如果你的任务出现异常没有捕获，会导致后续的任务不再执行，所以一定要try...catch
1. 延迟不循环任务schedule方法
schedule(Runnable command, long delay, TimeUnit unit)
参数1：任务
参数2：方法第一次执行的延迟时间
参数3：延迟单位
说明：延迟任务，只执行一次(不会再次执行)，参数2为延迟时间
案例说明：
@Component
@Slf4j
public class MineExecutors {
private final static ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(5);
private final static SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:sss");
@PostConstruct
public void init() {
scheduler.schedule(() -> {
try {
log.info("开始执行...time {}", format.format(new Date()));
Thread.sleep(1000);
log.info("执行结束...time {}", format.format(new Date()));
} catch (Exception e) {
log.error("定时任务执行出错");
}
}, 5, TimeUnit.SECONDS);
log.info("初始化成功 {}", format.format(new Date()));
}
}可以看到任务执行时间为初始化完成后5s才开始执行，且只执行一次
2. 延迟且循环cheduleAtFixedRate方法
cheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)
参数1：任务
参数2：初始化完成后延迟多长时间执行第一次任务
参数3：任务时间间隔
参数4：单位
方法解释：是以上一个任务开始的时间计时，比如period为5，那5秒后，检测上一个任务是否执行完毕，如果上一个任务执行完毕，则当前任务立即执行，如果上一个任务没有执行完毕，则需要等上一个任务执行完毕后立即执行，如果你的任务执行时间超过5秒，那么任务时间间隔参数将无效，任务会不停地循环执行，由此可得出该方法不能严格保证任务按一定时间间隔执行
错误：任务连续执行案例：
@Component
@Slf4j
public class MineExecutors {
private final static ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(5);
private final static SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@PostConstruct
public void init() {
scheduler.scheduleAtFixedRate(() -> {
try {
log.info("开始执行...time {}", format.format(new Date()));
Thread.sleep(3000);
log.info("执行结束...time {}", format.format(new Date()));
} catch (Exception e) {
log.error("定时任务执行出错");
}
}, 0, 2, TimeUnit.SECONDS);
log.info("初始化成功 {}", format.format(new Date()));
}
}由上面代码可以看出，任务执行需要3秒，而我们设定的任务时间间隔为2秒，如此就会导致任务连续执行，该方法不能严格保证任务按照规定的时间间隔执行，如果你的任务执行时间可以保证忽略不计，则可以使用该方法，我们可以看到下面日志，上一个任务的执行结束时间与下一个任务的开始时间一致，所以任务连续循环执行了
正确案例：
@Component
@Slf4j
public class MineExecutors {
private final static ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(5);
private final static SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@PostConstruct
public void init() {
scheduler.scheduleAtFixedRate(() -> {
try {
log.info("开始执行...time {}", format.format(new Date()));
Thread.sleep(1000);
log.info("执行结束...time {}", format.format(new Date()));
} catch (Exception e) {
log.error("定时任务执行出错");
}
}, 0, 3, TimeUnit.SECONDS);
log.info("初始化成功 {}", format.format(new Date()));
}
}可以看到任务以上一次任务的开始时间，按3秒一次的方式执行
3. 严格按照一定时间间隔执行``
scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit);
参数1：任务
参数2：初始化完成后延迟多长时间执行第一次任务
参数3：任务执行时间间隔
参数4：单位
解释：以上一次任务执行结束时间为准，加上任务时间间隔作为下一次任务开始时间，由此可以得出，任务可以严格按照时间间隔执行
案例：
@Component
@Slf4j
public class MineExecutors {
private final static ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(5);
private final static SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@PostConstruct
public void init() {
scheduler.scheduleWithFixedDelay(() -> {
try {
log.info("开始执行...time {}", format.format(new Date()));
Thread.sleep(5000);
log.info("执行结束...time {}", format.format(new Date()));
} catch (Exception e) {
log.error("定时任务执行出错");
}
}, 0, 3, TimeUnit.SECONDS);
log.info("初始化成功 {}", format.format(new Date()));
}
}由下图日志可以看出，下次任务的开始时间是在上一次任务结束时间+任务时间间隔为准的，严格按照任务时间间隔，规律执行，如果你的任务需要保证严格的时间间隔，可以用该方法启动任务
其他用法与线程池没有差异了，例如ThreadFactory作为参数传入，自定义线程池内线程名称之类的，不多解释了。
到此这篇关于Java ScheduledExecutorService的具体使用的文章就介绍到这了,更多相关ScheduledExecutorService内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
这篇文章主要为大家详细介绍了java DateUtil工具类时间戳类型转换的相关资料，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2017-12-12
今天小编就为大家分享一篇关于MapTask工作机制图文详解，小编觉得内容挺不错的，现在分享给大家，具有很好的参考价值，需要的朋友一起跟随小编来看看吧2019-01-01
SpringBoot详细分析自动装配原理并实现starter
相对于传统意义上的Spring项目，SpringBoot具有开箱即用，简化配置，内置Tomcat等等等等一系列的特点。在这些特点中，最重要的两条就是约定优于配置和自动装配2022-07-07
这篇文章主要为大家详细介绍了Java日期工具类DateUtils实例，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2017-12-12
基于springboot bean的实例化过程和属性注入过程
这篇文章主要介绍了基于springboot bean的实例化过程和属性注入过程，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-11-11
这篇文章主要介绍了使用Java实现简单串口通信，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-07-07
在现在的JavaEE开发过程中,我们经常会使用到Spring+SpringMVC+Mybatis这个组合,那么Mybatis是如何集成到Spring中的呢,下面通过实例代码给大家详细讲解,感兴趣的朋友跟随小编一起看看吧2024-03-03
springboot如何实现异步响应请求(前端请求超时的问题解决)
这篇文章主要给大家介绍了关于springboot如何实现异步响应请求(前端请求超时的问题解决)的相关资料,文中通过实例代码介绍的非常详细,对大家学习或者使用springboot具有一定的参考学习价值,需要的朋友可以参考下2023-01-01
这篇文章主要介绍了Java绘图技术的详解及实例的相关资料,这里主要详解Graphics类的使用，需要的朋友可以参考下2017-08-08
开发人员通常认为拥有final引用，或者val在Kotlin或Scala中，足以使对象不可变。这篇博客文章深入研究了不可变引用和不可变数据结构，下面小编来和大家一起学习它2019-05-05
最新评论