今天就跟大家聊聊有关springboot2中怎么异步处理任务,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。
10年积累的成都做网站、网站设计、外贸营销网站建设经验,可以快速应对客户对网站的新想法和需求。提供各种问题对应的解决方案。让选择我们的客户得到更好、更有力的网络服务。我虽然不认识你,你也不认识我。但先网站设计后付款的网站建设流程,更有永康免费网站建设让你可以放心的选择与我们合作。
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中怎么异步处理任务有进一步的了解吗?如果还想了解更多知识或者相关内容,请关注创新互联行业资讯频道,感谢大家的支持。