浅析java中常用的定时任务框架

目录

一、阅读收获二、本章源码下载三、timer+timertask四、scheduledexecutorrvice五、spring task5.1 单线程串行执行-@scheduled5.2 多线程并发运行-@scheduled+配置定时器的程池（推荐）5.3 多线程并发执行-@scheduled+@async+配置异步线程池5.4 @scheduled参数解析六、quartz6.1. 创建任务类6.2. 配置任务描述和触发器

一、阅读收获

1. 了解常用的单体应用定时任务框架

2. 掌握定时任务在单体中如何使用

二、本章源码下载

本章源码下载已分享github

三、timer+timertask

这是jdk自带的java.util.timer类，这个类允许你调度一个java.util.timertask任务。使用这种方式可以让你的程序按照某一个频度执行，但不能在指定时间运行,一般用的较少。

/** * @description: 1. timer+timertask：（jdk自带） * 这是java自带的java.util.timer类，这个类允许你调度一个java.util.timertask任务。 * 使用这种方式可以让你的程序按照某一个频度执行，但不能在指定时间运行。一般用的较少。 * @author: jianweil * @date: 2021/12/14 13:36 */public class timertest {    public static void main(string[] args) {        timertask timertask = new timertask() {            @override            public void run() {                system.out.println("task  run:" + new date());            }        };        timertask timertask2 = new timertask() {            @override            public void run() {                system.out.println("task2  run:" + new date());                //多线程并行处理定时任务时，timer运行多个timetask时，只要其中之一没有捕获抛出的异常，其它任务便会自动终止运行，使用scheduledexecutorrvice则没有这个问题。                int i = 1/0;            }        };        //idea会提示：使用scheduledexecutorrvice代替timer吧        timer timer = new t欧也妮葛朗台简介imer();        system.out.println("begin:" + new date());        //安排指定的任务在指定的时间开始进行重复的固定延迟执行。这里是延迟5秒开始执行，之后每3秒执行一次        timer.schedule(timertask, 5000, 3000);        timer.schedule(timertask2, 5000, 3000);    }}

多线程并行处理定时任务时，timer运行多个timetask时，只要其中之一没有捕获抛出的异常，其它任务便会自动终止运行，使用scheduledexecutorrvice则没有这个问题。

四、scheduledexecutorrvice

scheduledexecutorrvice也是jdk自带的定时类，可以替代timer

package com.ljw.springboottimer.scheduledexecutorrvice;import org.apache.commons.lang3.concurrent.basicthreadfactory;import java.util.date;import java.util.concurrent.scheduledexecutorrvice;import java.util.concurrent.scheduledthreadpoolexecutor;import java.util.concurrent.timeunit;/** * @description: 2. scheduledexecutorrvice代替timer（jdk自带） * 多线程并行处理定时任务时，timer运行多个timetask时，只要其中之一没有捕获抛出的异常，其它任务便会自动终止运行， * 使用scheduledexecutorrvice则没有这个问题。 * @author: jianweil * @date: 2021/12/14 13:42 */public class scheduledexecutorrvicetest {    public static void main(string[] args) throws interruptedexception {        //当所有的非守护线程结束时，程序也就终止了，同时会杀死进程中的所有守护线程。反过来说，只要任何非守护线程还在运行，程序就不会终止。        scheduledexecutorrvice executorrvice = new scheduledthreadpoolexecutor(1,                new basicthreadfactory.builder().namingpattern("example-schedule-pool-%d").daemon(fal).build());        system.out.println("begin:" + new date());        // 参数：1、任务体 2、首次执行的延时时间 3、任务执行间隔 4、间隔时间单位        //延迟5秒执行，之后每3秒执行一次        executorrvice.scheduleatfixedrate(new runnable() {            @override            public void run() {                //do something                system.out.println("begin:" + new date());            }        }, 5, 3, timeunit.conds);    }}

五、spring task

spring提供的类，可引入依赖：

<dependency>    <groupid>org.springframework.boot</groupid>    <artifactid>spring-boot-starter</artifactid></dependency>

开启定时任务：@enablescheduling

使用：在相应的任务方法前加上注解@scheduled即可

5.1 单线程串行执行-@scheduled

@scheduled注解默认使同一个线程中串行执行，如果只有一个定时任务，这样做肯定没问题，当定时任务增多，如果一个任务卡死，会导致其他任务也无法执行。

业务测试：

@component@enableschedulingpublic class springtasktest {    @scheduled(cron = "0/5 * * * * *")    public void run() throws interruptedexception {        system.out.println(thread.currentthread().getname() + "=====>>>>>使用cron  {}" + (system.currenttimemillis() / 1000));    }} 

5.2 多线程并发运行-@scheduled+配置定瞬时速度怎么算时器的程池（推荐）

解决单线程串行执行任务的问题，需要配置定时器的程池，推荐这种方法配置并注入一个taskscheduler类bean即可配置定时器的线程池类如下：

package com.ljw.springboottimer.springtask;import org.springframework.context.annotation.bean;import org.springframework.context.annotation.configuration;import org.springframework.scheduling.taskscheduler;import org.springframework.scheduling.concurrent.threadpooltaskscheduler;/** * @description: 解决单线程串行执行 方式2:@scheduled+配置定时器的线程池 * @author: jianweil * @date: 2021/12/14 14:44 */@configurationpublic class taskschedulerconfig {    /**     * 初始化了一个线程池大小为 5  的 taskscheduler, 避免了所有任务都用一个线程来执行     *     * @return     */    @bean    public taskscheduler taskscheduler() {        threadpooltaskscheduler taskscheduler = new threadpooltaskscheduler();        taskscheduler.tpoolsize(5);        taskscheduler.tthreadnameprefix("taskschedulerconfig-ljw");        return taskscheduler;    }}

业务测试

@component@enableschedulingpublic class springtasktest {    @scheduled(考1考cron = "0/5 * * * * *")    public void run() throws interruptedexception {        system.out.println(thread.currentthread().getname() + "=====>>>>>使用cron  {}" + (system.currenttimemillis() / 1000));    }        @scheduled(fixedrate = 5000)    public void run1() throws interruptedexception {        system.out.println(thread.currentthread().getname() + "=====>>>>>使用fixedrate  {}" + (system.currenttimemillis() / 1000));    }} 

5.3 多线程并发执行-@scheduled+@async+配置异步线程池

解决单线程串行执行任务的问题，也可以结合异步注解@async实现，但这种方法并不推荐，需要两个注解，代码编写的工作量大

还可以解决fixedrate在遇到某些执行任务时间超过配置的时间隔，下次任务时间到了还要等待上次任务执行完成的情况，这是3.2不能解决的。

配置异步线程池类如下：

package com.ljw.springboottimer.springtask;import org.springframework.context.annotation.configuration;import org.springframework.scheduling.annotation.asyncconfigurer;import org.springframework.scheduling.annotation.enableasync;import org.springframework.scheduling.concurrent.threadpooltaskexecutor;import java.util.concurrent.executor;import java.util.concurrent.threadpoolexecutor;/** * @description: 解决单线程串行执行 方式1:@scheduled+@async+配置异步线程池 * @author: jianweil * @date: 2021/12/14 14:35 */@configuration@enableasyncpublic class asyncconfig implements asyncconfigurer {    /**     * 定义@async默认的线程池     * threadpooltaskexecutor不是完全被ioc容器管理的bean,可以在方法上加上@bean注解交给容器管理,这样可以将taskexecutor.initialize()方法调用去掉，容器会自动调用     *     * @return     */    @override    public executor getasyncexecutor() {        int processors = runtime.getruntime().availableprocessors();        //常用的执行器        threadpooltaskexecutor taskexecutor = new threadpooltaskexecutor();        //核心线程数        taskexecutor.tcorepoolsize(10);        taskexecutor.tmaxpoolsize(50);        //线程队列最大线程数,默认：50        taskexecutor.tqueuecapacity(100);        //线程名称前缀        taskexecutor.tthreadnameprefix("asyncconfig-ljw-");        taskexecutor.trejectedexecutionhandler(new threadpoolexecutor.callerrunspolicy());        //执行初始化(重要)        taskexecutor.initialize();        return taskexecutor;    }}

业务测试需要加上@async注解

@component@enableschedulingpublic class springtasktest {    @scheduled(cron = "0/5 * * * * *")    @async    public void run() throws interruptedexception {        system.out.println(thread.currentthread().getname() + "=====>>>>>使用cron  {}" + (system.currenttimemillis() / 1000));    }        @scheduled(fixedrate = 5000)    @async    public void run1() throws interruptedexception {        system.out.println(thread.currentthread().getname() + "=====>>>>>使用fixedrate  {}" + (system.currenttimemillis() / 1000));    }} 

如果同时配置了3.2配置定时器的程池和3.3配置异步线程池，并且注解使用了@scheduled+@async，则定时任务使用的线程池为：配置异步线程池

5.4 @scheduled参数解析

cron：通过cron表达式来配置任务执行时间（默认是fixeddelay）

initialdelay ：定义该任务延迟多少时间才开始第一次执行

fixedrate：定义一个按一定频率执行的定时任务。fixedrate 每次任务结束后会从任务编排表中找下一次该执行的任务，判断是否到时机执行，fixedrate的任务某次执行时间再长也不会造成两次任务实例同时执行，也要等到上次任务完成，判断是否到时机执行，到就立即执行，与线程池无关，除非用了@async注解，使方法异步，即是使用5.3步骤的配置。（5.2是配置线程池，达不到效果）

fixeddelay：定义一个按一定频率执行的定时任务。fixeddelay总是在前一次任务完成后，延时固定时间长度然后再执行下一次任务

六、quartz

在开发quartz相关应用时，只要定义了job（任务），jobdetail（任务描述），trigger（触发器）和scheduler（调度器），即可实现一个定时调度能力。

如果springboot版本是2.0.0以后的，则在spring-boot-starter中已经包含了quart的依赖，则可以直接引入依赖：

<dependency>    <groupid>org.springframework.boot</groupid>    <artifactid>spring-boot-starter-quartz</artifactid></dependency>

6.1. 创建任务类

方式1：实现job类的execute方法即可实现一个任务（推荐）

任务1如下：

package com.ljw.springboottimer.quartz.do1;import org.quartz.job;import org.quartz.jobexecutioncontext;import org.qu卫校是什么artz.jobexecutionexception;import java.util.date;/** * @description: 我的定时任务-方法1 * @author: jianweil * @date: 2021/12/14 16:06 */public class mytaskrvice1 implements job {    @override    public void execute(jobexecutioncontext jobexecutioncontext) throws jobexecutionexception {        system.out.println(thread.currentthread().getname() + "------ job ------" + new date());    }}

方式2：继承quartzjobbean类重写方法即可实现一个任务

任务2如下：

package com.ljw.springboottimer.quartz.do1;import org.quartz.jobexecutioncontext;import org.quartz.jobexecutionexception;import org.springframework.scheduling.quartz.quartzjobbean;import java.util.date;/** * @description: 我的定时任务-方法2 * @author: jianweil * @date: 2021/12/14 16:06 */public class mytaskrvice2 extends quartzjobbean {    @override    protected void executeinternal(jobexecutioncontext context) throws jobexecutionexception {        system.out.println(thread.currentthread().getname() + "---quartzjobbean-----" + new date());    }}

6.2. 配置任务描述和触发器

配置类要分别要为每个任务声明两个bean

1.jobdetail（任务描述）2.trigger（触发器）

配置调度器信息使用simpleschedulebuilder或者cronschedulebuilder

package com.ljw.springboottimer.quartz.do1;import org.quartz.*;import org.springframework.context.annotation.bean;import org.springframework.context.annotation.configuration;import java.util.date;/** * @description: 每个任务都要两步配置 * 1.配置任务描述jobdetail 2. 配置触发器trigger * @author: jianweil * @date: 2021/12/14 16:08 */@configurationpublic class quartzconfig {    /**     * 创建任务1的 jobdetail1     *     * @return     */    @bean    public jobdetail teatquartzdetail1() {        return jobbuilder.newjob(mytaskrvice1.class)                //job的描述                .withdescription("this is a job1")                //job 的name和group                .withidentity("mytrigger1", "mytriggergroup1")                .storedurably().build();    }    /**     * 创建任务2的 jobdetail2     *     * @return     */    @bean    public jobdetail teatquartzdetail2() {        return jobbuilder.newjob(mytaskrvice2.class)              英语必修一单词  //job的描述                .withdescription("this is a job2")                //job 的name和group                .withidentity("mytrigger2", "mytriggergroup2")                .storedurably().build();    }    /**     * 创建任务1的 trigger1     *     * @return     */    @bean    public trigger testquartztrigger1() {        //使用simpleschedulebuilder或者cronschedulebuilder        simpleschedulebuilder schedulebuilder = simpleschedulebuilder.simpleschedule()                //设置时间周期单位秒                .withintervalinconds(10)                .repeatforever();        //两秒执行一次，quartz表达式，支持各种牛逼表达式        cronschedulebuilder cronschedulebuilder = cronschedulebuilder.cronschedule("0/3 * * * * ?");        //任务运行的时间，simpleschedle类型触发器有效，3秒后启动任务        long time = system.currenttimemillis() + 3 * 1000l;        date stattime = new date(time);        return triggerbuilder.newtrigger()                .withdescription("")                .forjob(teatquartzdetail1())                .withidentity("mytrigger1", "mytriggergroup1")                //默认当前时间启动                .startat(stattime)                .withschedule(cronschedulebuilder)                //.withschedule(schedulebuilder)                .build();    }    /**     * 创建任务2的 trigger2     *     * @return     */    @bean    public trigger testquartztrigger2() {        simpleschedulebuilder schedulebuilder = simpleschedulebuilder.simpleschedule()                //设置时间周期单位秒                .withintervalinconds(10)                .repeatforever();        return triggerbuilder.newtrigger()                .forjob(teatquartzdetail2())                .withidentity("mytrigger2", "mytriggergroup2")                .withschedule(schedulebuilder)                .build();    }} 

以上就是浅析java中常用的定时任务框架-单体的详细内容，更多关于java定时任务框架的资料请关注www.887551.com其它相关文章！