Spring提供了两种后台任务的方法,分别是:

  1. 调度任务，@Schedule
  2. 异步任务，@Async

当然，使用这两个是有条件的，需要在spring应用的上下文中声明
<task:annotation-driven/>当然，如果我们是基于java配置的，需要在配置哪里加多EnableScheduling和@EnableAsync 就像下面这样

1
2
3
4
5
6
@EnableScheduling
@EnableAsync
public class WebAppConfig {
....
｝

除此之外，还是有第三方库可以调用的，例如Quartz.

@Schedule

先看下@Schedule怎么调用再说

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
public final static long ONE_DAY = 24 * 60 * 60 * 1000;
public final static long ONE_HOUR = 60 * 60 * 1000;
@Scheduled(fixedRate = ONE_DAY)
public void scheduledTask() {
System.out.println(" 我是一个每隔一天就会执行一次的调度任务");
}
@Scheduled(fixedDelay = ONE_HOURS)
public void scheduleTask2() {
System.out.println(" 我是一个执行完后，隔一小时就会执行的任务");
}
@Scheduled(initialDelay=1000, fixedRate=5000)
public void doSomething() {
// something that should execute periodically
}
@Scheduled(cron = "0 0/1 * * * ? ")
public void ScheduledTask3() {
System.out.println(" 我是一个每隔一分钟就就会执行的任务");
}

需要注意的

  1. 关于最后一个，在指定时间执行的任务，里面使用的是Cron表达式，同时我们看到了两个不一样的面孔fixedDelay& fixedRate，前者fixedDelay表示在指定间隔运行程序，例如这个程序在今晚九点运行程序，跑完这个方法后的一个小时，就会再执行一次，而后者fixedDelay者是指，这个函数每隔一段时间就会被调用（我们这里设置的是一天），不管再次调度的时候，这个方法是在运行还是结束了。而前者就要求是函数运行结束后开始计时的，这就是两者区别。

  2. 这个还有一个initialDelay的参数，是第一次调用前需要等待的时间，这里表示被调用后的，推迟一秒再执行，这适合一些特殊的情况。

  3. 我们在serviceImpl类写这些调度任务时候，也需要在这些我们定义的serviceInterface的借口中写多这个接口，要不然会爆 but not found in any interface(s) for bean JDK proxy.Either pull the method up to an interface or

@Async

有时候我们会调用一些特殊的任务，任务会比较耗时，重要的是，我们不管他返回的后果。这时候我们就需要用这类的异步任务啦，调用后就让他去跑，不堵塞主线程，我们继续干别的。代码像下面这样:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
public void AsyncTask(){
@Async
public void doSomeHeavyBackgroundTask(int sleepTime) {
try {
Thread.sleep(sleepTime);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
@Async
public Future<String> doSomeHeavyBackgroundTask() {
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
return null;
}
public void printLog() {
System.out.println(" i print a log ,time=" + System.currentTimeMillis());
}
}

我们写个简单的测试类来测试下

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
@RunWith(SpringJUnit4ClassRunner.class)
@WebAppConfiguration
@ContextConfiguration(classes = AsycnTaskConfig.class) //要声明@EnableASync
public class AsyncTaskTest {
@Autowired
AsyncTask asyncTask;
@Test
public void AsyncTaskTest() throws InterruptedException {
if (asyncTask != null) {
asyncTask.doSomeHeavyBackgroundTask(4000);
asyncTask.printLog();
Thread.sleep(5000);
}
}
}

这感觉比我们手动开多一个线程方便多了，不想异步的话直接把@Async去掉就可以了，另外如果你想要返回个结果的，这需要加多个Future<>,关于这个Future，完全可以写多几篇文章介绍，顺便把FutureTask介绍了。如果想修改Spring boot的默认线程池配置，可以实现AsyncConfigurer.
需要注意的：

  1. 相对于@scheduled，这个可以有参数和返回个结果，因为这个是我们调用的，而调度的任务是spring调用的。
  2. 异步方法不能内部调用，只能像上面那样，外部调用，否则就会变成阻塞主线程的同步任务啦！这个坑我居然跳下去了！例如下面这样的。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
public void AsyncTask(){
public void fakeAsyncTaskTest(){
doSomeHeavyBackgroundTask(4000);
printLog();
//你会发现，当你像这样内部调用的时候，居然是同步执行的，不是异步的！！
}
@Async
public void doSomeHeavyBackgroundTask(int sleepTime) {
try {
Thread.sleep(sleepTime);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public void printLog() {
System.out.println(" i print a log ");
}
}
  1. 另外一点就是不要重复的扫描，这也会导致异步无效，具体的可以看这个stackoveflow的spring-async-not-working Issue。
  2. 关于异常处理，难免在这个异步执行过程中有异常发生，对于这个问题，spring提供的解决方案如下,实现 AsyncUncaughtExceptionHandler接口。
1
2
3
4
5
6
7
8
9
10
11
public class MyAsyncUncaughtExceptionHandler implements
AsyncUncaughtExceptionHandler {
@Override
public void handleUncaughtException(Throwable ex,
Method method, Object... params) {
// handle exception
}
}

写好我们的异常处理后，我们需要配置一下，告诉spring，这个异常处理就是我们在运行异步任务时候，抛出错误时的异常终结者

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {
@Bean
public AsyncTask asyncBean() {
return new AsyncTask();
}
@Override
public Executor getAsyncExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(7);
executor.setMaxPoolSize(42);
executor.setQueueCapacity(11);
executor.setThreadNamePrefix("MyExecutor-");
executor.initialize();
return executor;
}
@Override
public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
return new MyAsyncUncaughtExceptionHandler();
}
}

Quartz登场

处理这两个外，还有一个和spring整合的第三方库叫Quartz
看了下官网的使用简介，也是挺逗的，现在都习惯用maven，gradle之类来关系这些依赖了，他还叫人下载，也是不知为何，详情点击－>
http://quartz-scheduler.org/documentation/quartz-2.2.x/quick-start
估计有可能是因为没再维护了的原因吧，看了下，最新版2.2居然是Sep, 2013更新的…
居然是停更的，不过Quartz作为一个企业级应用的任务调度框架，还是一个可以的候选项目的。
这里不铺开讲，有兴趣就去官网看下吧。整体用起来感觉是没有spring自己的后台任务方便，不过也可以接受，只需要简单的配置就可以使用了。

http://www.cnblogs.com/slimer/p/6401394.html

转载于:https://www.cnblogs.com/softidea/p/6855034.html

Spring的两种任务调度Scheduled和Async相关推荐

  1. Spring AOP两种实现机制是什么？

    Spring AOP两种实现机制是什么? 1.如果是有接口声明的类进行AOP 时,spring调用的是java.lang.reflection.Proxy 类来做处理 2.如果是没有接口声明的类时, ...

  2. Java框架篇---spring aop两种配置方式

    Java框架篇---spring aop两种配置方式 第一种:注解配置AOP 注解配置AOP(使用 AspectJ 类库实现的),大致分为三步:  1. 使用注解@Aspect来定义一个切面,在切面中 ...

  3. Spring中两种编程式事务管理

    Spring中两种编程式事务管理 在代码中显示调用beginTransaction,commit,rollback等与事务处理相关的方法,这就是编程式事务管理,当只有少数事务操作时,编程式事务管理才比 ...

  4. Spring AOP两种使用方式以及如何使用解析

    AOP是一种面向切面编程思想,也是面向对象设计(OOP)的一种延伸. 在Spring实现AOP有两种实现方式,一种是采用JDK动态代理实现,另外一种就是采用CGLIB代理实现,Spring是如何实现的 ...

  5. Spring的两种代理方式：JDK动态代理和CGLIB动态代理

    代理模式 代理模式的英文叫做Proxy或Surrogate,中文都可译为"代理",所谓代理,就是一个人或者一个机构代表另一个人或者另一个机构采取行动.在一些情况下,一个客户不想或者 ...

  6. Spring的两种动态代理：Jdk和Cglib 的区别和实现

    这是有意义的一天!自己研究一路畅通的感觉真爽 原理是参考大神的,代码手敲 一.原理区别: java动态代理是利用反射机制生成一个实现代理接口的匿名类,在调用具体方法前调用InvokeHandler来处 ...

  7. struts2和spring的两种整合方式 action的自动装配

    http://www.cnblogs.com/taoxiaoji/archive/2011/03/12/Two_ways_to_integrate_Struts2_and_Spring.html st ...

  8. Spring的两种容器后处理器（PropertyPlaceholderConfigurer和PropertyOverrideConfigurer）

    一.容器后处理器 Spring有如下几个常用容器后处理器: PropertyPlaceholderConfigurer:属性点位符配置器 PropertyOverrideConfigurer:重写占位 ...

  9. Spring的两种属性注入方式

    Spring包下载地址:http://repo.spring.io/release/org/springframework/spring/ jar包下载:http://www.manyjar.com/ ...

最新文章

  1. Hadoop HDFS的一些相关代码code
  2. 使用VSIUAL C#.NET操作Excel －把DataTable中的数据写入Excel
  3. 蓝牙的发展史及版本演进
  4. Android 用户界面---拖放（Drag and Drop）（二）
  5. Pandas 文本数据方法 contains()
  6. android 梅花布局,Android相对布局实现各种梅花效果
  7. Highcharter绘制中国地图
  8. 微信计数器|微信自动加好友|微信自动通过好友|微信HOOK|微信静默清粉
  9. html制作简单扫雷,JavaScript制作windows经典扫雷小游戏
  10. 软件工程——软件开发模型
  11. 跟着实训团初学HTML的第一天
  12. 关于电脑网速网占用问题（svchost.exe）（￥72）
  13. Windows10系统登陆界面“出现问题，PIN不可用”-解决方法
  14. win10与virtualBox共享文件夹
  15. 手游平台开发需要哪些人员配置？
  16. 江苏计算机一级视频教程,江苏省计算机一级江苏省计算一级机一级.ppt
  17. mysql for mac 10.12_mac 10.12 版本 安装mysql - sylvia的博客
  18. 中年危机如何化解分析
  19. arch检验python_arch效应检验的一些要点
  20. facebook rebound

热门文章

  1. 二级指针、数组指针、二维数组、指针数组作为函数形参时可传入的实参
  2. linux kset subsystem 3.10内核,Kobject、Kset 和 Subsystem
  3. c语言用指针变量输入数组的长度,C语言之数组的基础练习题（指针变量做函数参数）...
  4. Linux使用ftp传输10g的文件,Ubuntu 16.04 安装ftp服务器传输文件
  5. PHP的html实现xpath解析,php用xpath解析html的代码实例讲解
  6. php枚举mysql,小技巧：取得MYSQL中ENUM（枚举）列的全部可能值。-PHP教程,PHP应用...
  7. mysql+linux+无法启动服务无法启动不了_Linux实例中MySQL服务常见的无法启动或启动异常处理...
  8. keras优化算法_目标检测算法 - CenterNet - 代码分析
  9. wedo2.0编程模块介绍_福特福克斯TCM重新编程操作
  10. Java基础总结之（面试）