Java定时任务ScheduledThreadPoolExecutor示例详解

 更新时间:2023年11月30日 11:48:24   作者:煮酒泛舟  
这篇文章主要介绍了Java定时任务ScheduledThreadPoolExecutor示例详解,这里使用scheduleAtFixedRate方法安排一个任务,该任务是一个 Runnable 匿名类,其run方法中调用了new LoginViewTimeTask().loginStatisticsHandle()方法,需要的朋友可以参考下

ScheduledThreadPoolExecutor 的创建

ScheduledThreadPoolExecutor executorService = new ScheduledThreadPoolExecutor(
        1, // 核心线程数
        new BasicThreadFactory.Builder()
                .namingPattern("example-schedule-pool-%d") // 线程命名规则
                .daemon(true) // 设置线程为守护线程
                .build()
);

这里创建了一个大小为1的定时任务线程池,使用了 BasicThreadFactory 来设置线程的命名规则为 “example-schedule-pool-1”,并将线程设置为守护线程。

定时任务的执行

executorService.scheduleAtFixedRate(
        new Runnable() {
            @Override
            public void run() {
                try {
                    new LoginViewTimeTask().loginStatisticsHandle();
                } catch (Exception e) {
                    Global.getInstance().LogError(e);
                }
            }
        },
        1000 * 60, // 初次执行延迟时间,这里是1分钟
        1000 * 60 * 60 * 24, // 固定间隔时间,这里是1天
        TimeUnit.HOURS // 时间单位,这里是小时
);

这里使用 scheduleAtFixedRate 方法安排一个任务,该任务是一个 Runnable 匿名类,其 run 方法中调用了 new LoginViewTimeTask().loginStatisticsHandle() 方法。这个任务将在初始延迟后以固定的时间间隔重复执行。

具体参数解释

  • 初次执行延迟时间:1000 * 60 毫秒,即1分钟。
  • 固定间隔时间:1000 * 60 * 60 * 24 毫秒,即1天。
  • 时间单位:TimeUnit.HOURS,表示以上时间参数的单位是小时。

总体来说,这段代码的作用是创建一个定时任务,每隔一天执行一次 LoginViewTimeTask 类中的 loginStatisticsHandle 方法,初次执行延迟1分钟。如果 loginStatisticsHandle 方法中的逻辑是定期执行的任务,这样的定时任务可以用于定期统计登录信息。
ScheduledThreadPoolExecutor 本身没有直接提供设置初始执行时间的方法,但你可以通过计算初始延迟来实现类似的效果。可以使用 System.currentTimeMillis() 获取当前时间戳,然后计算出距离下一次执行的时间差。

设置初始执行时间

以下是一个示例代码,演示了如何在 ScheduledThreadPoolExecutor 中设置初始执行时间:

import java.util.Calendar;
import java.util.Date;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class ScheduledTaskExample {
    public static void main(String[] args) {
        // 创建一个 ScheduledExecutorService
        ScheduledExecutorService executorService = Executors.newScheduledThreadPool(1);
        // 获取当前时间
        long currentTimeMillis = System.currentTimeMillis();
        // 计算距离下一次执行的时间差(假设下一次执行是明天的这个时刻)
        Calendar calendar = Calendar.getInstance();
        calendar.add(Calendar.DAY_OF_YEAR, 1);
        calendar.set(Calendar.HOUR_OF_DAY, 12); // 设置小时
        calendar.set(Calendar.MINUTE, 0);      // 设置分钟
        calendar.set(Calendar.SECOND, 0);      // 设置秒
        calendar.set(Calendar.MILLISECOND, 0); // 设置毫秒
        long initialDelay = calendar.getTimeInMillis() - currentTimeMillis;
        // 执行任务,每隔一天执行一次
        executorService.scheduleAtFixedRate(
                new Runnable() {
                    @Override
                    public void run() {
                        // 任务逻辑
                        System.out.println("Task executed at: " + new Date());
                    }
                },
                initialDelay,  // 初始延迟时间
                24,            // 间隔时间
                TimeUnit.HOURS // 时间单位
        );
    }
}

在这个例子中,initialDelay 计算了当前时间到明天的指定时刻的时间差。这样,第一次执行任务的时间就被设定为明天的这个时刻。后续的任务将会在每隔24小时执行一次。你可以根据需要调整计算初始延迟的逻辑。

到此这篇关于Java定时任务 ScheduledThreadPoolExecutor的文章就介绍到这了,更多相关Java定时任务 ScheduledThreadPoolExecutor内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Mybatis Plus分页查询返回total为0问题解决

    Mybatis Plus分页查询返回total为0问题解决

    在使用MybatisPlus进行分页查询时,可能会遇到返回的总条数(total)为0的问题,这通常是由于未配置MybatisPlus的分页插件拦截器导致的,本文就来介绍一下解决方法,感兴趣的可以了解一下
    2024-10-10
  • java解析Excel/导入信息到Excel方式

    java解析Excel/导入信息到Excel方式

    这篇文章主要介绍了java解析Excel/导入信息到Excel方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-11-11
  • 解读HttpServletRequestWrapper处理request数据流多次读取问题

    解读HttpServletRequestWrapper处理request数据流多次读取问题

    在Java Web开发中,获取HTTP请求参数是常见需求,本文详细讨论了通过POST方式获取参数的两种主要方法:使用request.getParameter()适用于application/x-www-form-urlencoded和multipart/form-data内容类型;而对于application/json类型的数据
    2024-10-10
  • JAVA  静态的单例的实例详解

    JAVA 静态的单例的实例详解

    这篇文章主要介绍了JAVA 静态的单例的实例详解的相关资料,这里提供了实例方法,来说名不仅实现了延迟加载,又可以保证线程安全,不影响系统性能,需要的朋友可以参考下
    2017-07-07
  • SpringBoot整合LocalDateTime的过程

    SpringBoot整合LocalDateTime的过程

    LocalDateTime 和 Date 是 Java 中处理日期和时间的两种不同的类,在 JDK8 中引入了 java.time 包,这篇文章主要介绍了SpringBoot整合LocalDateTime的过程,需要的朋友可以参考下
    2024-08-08
  • spring boot教程之全局处理异常封装

    spring boot教程之全局处理异常封装

    这篇文章主要给大家介绍了关于spring boot教程之全局处理异常封装的相关资料,文中通过示例代码介绍的非常详细,对大家学习或者使用spring boot具有一定的参考学习价值,需要的朋友们下面来一起学习学习吧
    2019-09-09
  • springbean的八种加载方式汇总

    springbean的八种加载方式汇总

    这篇文章主要介绍了springbean的八种加载方式,一种是XML方式声明bean,使用@Component及其衍生注解@Controller 、@Service、@Repository定义bean,还有其他方法,本文给大家介绍的非常详细,需要的朋友可以参考下
    2022-10-10
  • springboot运行时新增/更新外部接口的实现方法

    springboot运行时新增/更新外部接口的实现方法

    这篇文章主要介绍了springboot运行时新增/更新外部接口的实现方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2021-03-03
  • 深入浅析Java中普通代码块、构造代码块与静态代码块

    深入浅析Java中普通代码块、构造代码块与静态代码块

    这篇文章主要介绍了Java中普通代码块、构造代码块与静态代码块的相关资料,静态代码块>Main()>构造代码块 。非常不错,具有参考借鉴价值,需要的朋友可以参考下
    2016-08-08
  • Java实现动态代理

    Java实现动态代理

    本文给大家介绍的是java使用动态代理类实现动态代理的方法和示例,这里推荐给大家,有需要的小伙伴参考下吧
    2015-02-02

最新评论