详解spring多线程与定时任务
本篇主要描述一下spring的多线程的使用与定时任务的使用.
1.spring多线程任务的使用
spring通过任务执行器TaskExecutor来实现多线程与并发编程。通常使用ThreadPoolTaskExecutor来实现一个基于线程池的TaskExecutor.
首先你要实现AsyncConfigurer 这个接口,目的是开启一个线程池
代码如下:
package com.foreveross.service.weixin.test.thread; import java.util.concurrent.Executor; import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler; import org.springframework.context.annotation.ComponentScan; import org.springframework.context.annotation.Configuration; import org.springframework.scheduling.annotation.AsyncConfigurer; import org.springframework.scheduling.annotation.EnableAsync; import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; /** * 注入一个线程池 * @author mingge * */ @Configuration @ComponentScan("com.foreveross.service.weixin.test.thread") @EnableAsync public class TaskExecutorConfig implements AsyncConfigurer { @Override public Executor getAsyncExecutor() { ThreadPoolTaskExecutor taskExecutor=new ThreadPoolTaskExecutor(); taskExecutor.setCorePoolSize(5); taskExecutor.setMaxPoolSize(20); taskExecutor.setQueueCapacity(25); taskExecutor.initialize(); return taskExecutor; } @Override public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() { return null; } }
然后注入一个类,实现你的业务,并在你的Bean的方法中使用@Async注解来声明其是一个异步任务
代码如下:
package com.foreveross.service.weixin.test.thread; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; /** * 线程池任务 * @author mingge * */ @Service public class TaskService { @Async public void executeAsyncTask(int i){ System.out.println("执行异步任务:"+i); } @Async public void executeAsyncTask1(int i){ System.out.println("执行异步任务1:"+(i+i)); } }
最后通过测试,可以看到你的实现是异步执行了.
package com.foreveross.service.weixin.test.thread; import org.springframework.context.annotation.AnnotationConfigApplicationContext; /** * * @author mingge * */ public class Test { public static void main(String[] args) { AnnotationConfigApplicationContext context=new AnnotationConfigApplicationContext(TaskExecutorConfig.class); TaskService taskService=context.getBean(TaskService.class); for(int i=0;i<20;i++){ taskService.executeAsyncTask(i); taskService.executeAsyncTask1(i); } //最后可以根据结果可以看出结果是并发执行而不是顺序执行的呢 context.close(); } }
2.spring定时任务的使用
在java原生态中,我们使用timer就可以了,这里小编说一些在Spring中的定时任务的使用
package com.foreveross.service.weixin.test.thread; import org.springframework.context.annotation.ComponentScan; import org.springframework.context.annotation.Configuration; import org.springframework.scheduling.annotation.EnableScheduling; @Configuration @ComponentScan("com.foreveross.service.weixin.test.thread") @EnableScheduling//开启对定时器的支持 public class TaskSchedulerConfig { }
package com.foreveross.service.weixin.test.thread; import java.util.Date; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Service; @Service public class TimerTaskJob { @Scheduled(fixedRate=2000) public void test(){ System.out.println("我是定时任务:"+new Date().getSeconds()); } }
package com.foreveross.service.weixin.test.thread; import org.springframework.context.annotation.AnnotationConfigApplicationContext; public class TestTimer { public static void main(String[] args) { AnnotationConfigApplicationContext context=new AnnotationConfigApplicationContext(TaskSchedulerConfig.class); //context.close(); } }
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。
相关文章
mybatis-plus常用注解@TableId和@TableField的用法
本文主要介绍了mybatis-plus常用注解@TableId和@TableField的用法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧2023-04-04IDEA 2020.1打开时闪退的问题及解决方法(完美解决方法)
这篇文章主要介绍了IDEA 2020.1打开时闪退问题及解决方法,本文给大家分享我的处理方案,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2020-04-04解决springboot启动失败的问题('hibernate.dialect' not set)
这篇文章主要介绍了解决springboot启动失败的问题('hibernate.dialect' not set),具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教2021-12-12
最新评论