2020年11月3日大约 6 分钟SpringScheduled定时任务
使用maven3、Spring4.3构建、jdk7编译、运行在tomcat7.0中。
pom.xml：加入依赖
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.source>1.7</maven.compiler.source>
<maven.compiler.target>1.7</maven.compiler.target>
<org.springframework.version>4.3.29.RELEASE</org.springframework.version>
</properties>
<dependencies>
<!--SpringMVC依赖-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>${org.springframework.version}</version>
</dependency>
</dependencies>
添加Spring配置文件applicationContext.xml：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns="http://www.springframework.org/schema/beans"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:task="http://www.springframework.org/schema/task"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.3.xsd
http://www.springframework.org/schema/task
http://www.springframework.org/schema/task/spring-task-4.3.xsd">
<context:component-scan base-package="com.yyc"></context:component-scan>
<task:annotation-driven />
</beans>
web.xml：配置如下
<web-app>
<display-name>Archetype Created Web Application</display-name>
<context-param>
<param-name>contextConfigLocation</param-name>
<param-value>classpath:applicationContext.xml</param-value>
</context-param>
<listener>
<!--一定要有这个监听器-->
<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>
</web-app>
使用@Scheduled注解开启定时任务
package com.yyc;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.util.Date;
@Component
public class TaskImpl implements ITask{
@Override
@Scheduled(cron = "0/5 * * * * ? ") // cron表达式，每5秒执行一次
public void taskMethod() {
System.out.println("exec-"+new Date()+"--"+Thread.currentThread());
}
}
第一次使用@Scheduled注解进行定时任务使用，发现部署成功，但定时任务老是不执行。最终发现web.xml配置出现了问题，在web.xml中，只使用context-param标签初始化了Spring的配置文件，还需要加入ContextLoaderListener监听器的配置才可以。百度一波，网友说到：tomcat启动时会加载web.xml 、加载<listener> 和<context-param>属性，项目启动，会找这个监听器去查contextConfigLocation。
当有多个@Scheduled定时任务时，我们可以配置Scheduler，即调度线程池配置，可以实现多个定时任务并行执行。
先来看看未配置Scheduler的执行情况。定时任务1每5秒执行一次；定时任务2也是每5秒执行一次，但是在打印之前，我们sleep 10秒，所以定时任务2会每15秒输出一次。
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.util.Date;
@Component
public class TaskImpl implements ITask{
/**
* 定时任务1
*/
@Override
//@Async
@Scheduled(cron = "0/5 * * * * ? ")
public void taskMethod1() {
System.out.println("TASK1-"+new Date()+"--"+Thread.currentThread());
}
/**
* 定时任务2
* @throws InterruptedException
*/
@Override
@Scheduled(cron = "0/5 * * * * ? ")
public void taskMethod2() throws InterruptedException {
Thread.sleep(10*1000);
System.out.println("TASK2-"+new Date()+"--"+Thread.currentThread());
}
}
xml配置：
<context:component-scan base-package="com.yyc"></context:component-scan>
<task:annotation-driven />
输出结果：
TASK2-Wed Nov 04 15:13:30 CST 2020--Thread[pool-1-thread-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:13:30 CST 2020--Thread[pool-1-thread-1,5,RMI Runtime]
TASK2-Wed Nov 04 15:13:45 CST 2020--Thread[pool-1-thread-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:13:45 CST 2020--Thread[pool-1-thread-1,5,RMI Runtime]
TASK2-Wed Nov 04 15:14:00 CST 2020--Thread[pool-1-thread-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:14:00 CST 2020--Thread[pool-1-thread-1,5,RMI Runtime]
TASK2-Wed Nov 04 15:14:15 CST 2020--Thread[pool-1-thread-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:14:15 CST 2020--Thread[pool-1-thread-1,5,RMI Runtime]
TASK2-Wed Nov 04 15:14:30 CST 2020--Thread[pool-1-thread-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:14:30 CST 2020--Thread[pool-1-thread-1,5,RMI Runtime]
TASK2-Wed Nov 04 15:14:45 CST 2020--Thread[pool-1-thread-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:14:45 CST 2020--Thread[pool-1-thread-1,5,RMI Runtime]
可以清晰的看到，未配置Scheduler时，任务1和任务2是串行方式执行的，都是每过15秒才打印一次，说明任何一个任务都需要等待其它任务执行完成，都是线程pool-1-thread-1执行的。
xml配置：
<context:component-scan base-package="com.yyc"></context:component-scan>
<task:annotation-driven scheduler="dataScheduler"/>
<task:scheduler id="dataScheduler" pool-size="2"/>
输出结果：
TASK1-Wed Nov 04 15:35:50 CST 2020--Thread[dataScheduler-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:35:55 CST 2020--Thread[dataScheduler-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:36:00 CST 2020--Thread[dataScheduler-1,5,RMI Runtime]
TASK2-Wed Nov 04 15:36:00 CST 2020--Thread[dataScheduler-2,5,RMI Runtime]
TASK1-Wed Nov 04 15:36:05 CST 2020--Thread[dataScheduler-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:36:10 CST 2020--Thread[dataScheduler-1,5,RMI Runtime]
TASK2-Wed Nov 04 15:36:15 CST 2020--Thread[dataScheduler-2,5,RMI Runtime]
TASK1-Wed Nov 04 15:36:15 CST 2020--Thread[dataScheduler-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:36:20 CST 2020--Thread[dataScheduler-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:36:25 CST 2020--Thread[dataScheduler-1,5,RMI Runtime]
TASK2-Wed Nov 04 15:36:30 CST 2020--Thread[dataScheduler-2,5,RMI Runtime]
为了方便查看，我们有两个任务配置pool-size为2。通过输出可以发现任务1和任务2并行执行，任务1每5秒输出一次（调度线程dataScheduler-1），任务2每15秒输出一次（调度线程dataScheduler-2）。
这里引入另一个参数，可以看任务 1上方注释掉的 @Async 注解：这个注解，代表可以异步执行。异步执行的话，调度线程池就会不用当前调度线程来执行，而是交给 task:executor 这个执行线程池来执行。
我们使用@Async注解配置任务1，任务2不变：
@Async
@Scheduled(cron = "0/5 * * * * ? ")
public void taskMethod1() {
System.out.println("TASK1-"+new Date()+"--"+Thread.currentThread());
}
xml配置：
<context:component-scan base-package="com.yyc"></context:component-scan>
<task:annotation-driven scheduler="dataScheduler" executor="dataExecutor"/>
<task:scheduler id="dataScheduler" pool-size="2"/>
<task:executor id="dataExecutor" pool-size="10"/>
输出结果：
TASK1-Wed Nov 04 15:58:25 CST 2020--Thread[dataExecutor-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:58:30 CST 2020--Thread[dataExecutor-2,5,RMI Runtime]
TASK1-Wed Nov 04 15:58:35 CST 2020--Thread[dataExecutor-3,5,RMI Runtime]
TASK2-Wed Nov 04 15:58:35 CST 2020--Thread[dataScheduler-2,5,RMI Runtime]
TASK1-Wed Nov 04 15:58:40 CST 2020--Thread[dataExecutor-4,5,RMI Runtime]
TASK1-Wed Nov 04 15:58:45 CST 2020--Thread[dataExecutor-5,5,RMI Runtime]
TASK2-Wed Nov 04 15:58:50 CST 2020--Thread[dataScheduler-2,5,RMI Runtime]
TASK1-Wed Nov 04 15:58:50 CST 2020--Thread[dataExecutor-6,5,RMI Runtime]
TASK1-Wed Nov 04 15:58:55 CST 2020--Thread[dataExecutor-7,5,RMI Runtime]
TASK1-Wed Nov 04 15:59:00 CST 2020--Thread[dataExecutor-8,5,RMI Runtime]
TASK2-Wed Nov 04 15:59:05 CST 2020--Thread[dataScheduler-2,5,RMI Runtime]
TASK1-Wed Nov 04 15:59:05 CST 2020--Thread[dataExecutor-9,5,RMI Runtime]
TASK1-Wed Nov 04 15:59:10 CST 2020--Thread[dataExecutor-10,5,RMI Runtime]
TASK1-Wed Nov 04 15:59:15 CST 2020--Thread[dataExecutor-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:59:20 CST 2020--Thread[dataExecutor-2,5,RMI Runtime]
TASK2-Wed Nov 04 15:59:20 CST 2020--Thread[dataScheduler-2,5,RMI Runtime]
TASK1-Wed Nov 04 15:59:25 CST 2020--Thread[dataExecutor-3,5,RMI Runtime]
可以发现，任务1使用了@Async注解后，任务1的线程是 dataExecutor-1 到 dataExecutor-10，说明 dataScheduler-1 这个调度线程调度了任务1，但是交给了线程池中的dataExecutor中的执行线程来具体执行的；而任务2没有使用@Async注解，所以还是使用dataScheduler-2 这个调度线程调度任务2。
本文示例源码：点击下载
org.springframework.web.context.ContextLoaderListener这个监听器；此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。