今天就跟大家聊聊有关springboot2中怎么异步处理任务,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。
1、一般我们异步任务的话是通过线程池执行多线程,然后直接返回“任务异步执行中......”类似提示信息
/**
* 异步处理1:线程池,创建新线程处理
* @return str
*/
@RequestMapping(value = "asyncTask")
public String asyncTask(){
ExecutorService service = Executors.newFixedThreadPool(5);
pool.submit(thread1);
pool.submit(thread2);
pool.submit(thread3);
System.out.println("====>当前线程名:"+Thread.currentThread().getName());
pool.shutdown();
return "任务异步执行中......";
}
2、springBoot自身的一种异步方式,我们在想要异步执行的类的方法上加上@Async注解,在controller上加上@EnableAsync。本类方法加@Async注解不生效。
@Controller
@EnableAsync
public class IndexController {
@Autowired
private TestService testService;
/**
*
* 异步处理2:使用springBoot自带async注解
*
*/
@RequestMapping(value = "test1",method = RequestMethod.GET)
public String test1(){
testService.getTest1();//异步方法上加@Async注解的方法
System.out.println("====>"+Thread.currentThread().getName());
return "异步,正在解析......";
}
}
public class TestService {
/**
* 异步方法
* 有@Async注解的方法,默认就是异步执行的,会在默认的线程池中执行,
* 但是此方法不能在本类调用;启动类需添加直接开启异步执行@EnableAsync。
*
*/
@Async
public String getTest1() {
synchronized (this){
try {
for (int i = 1;i <= 100;i++){
System.out.println(Thread.currentThread().getName()+"====>异步:>"+i);
this.wait(2000);
}
return "====>执行异步任务完毕";
}catch (Exception ex){
ex.printStackTrace();
}
}
return Thread.currentThread().getName()+"====>执行完毕";
}
}
看完上述内容,你们对springboot2中怎么异步处理任务有进一步的了解吗?如果还想了解更多知识或者相关内容,请关注亿速云行业资讯频道,感谢大家的支持。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。