第一部分: 无返回值异步任务

当没有加入异步任务的时候,我们创建一个service ,里面的方法需要等待3秒才能完成, controller层写一个测试方法调用时间返回的接口, 直接调用,

下面是service层代码部分

package com.zz.amqp1.service;
import org.springframework.stereotype.Service;
import java.util.Date;
/**
* Description: 异步任务测试类
* User: zhouzhou
* Date: 2018-08-28
* Time: 13:30
*/
@Service
public class AsyncService {
public void doNoReturn(){
try {
// 这个方法执行需要三秒
Thread.sleep(3000);
System.out.println("方法执行结束" + new Date());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}

下面是controller层代码部分

package com.zz.amqp1.controller;
import com.zz.amqp1.service.AsyncService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
/**
* Description: 异步任务测试类
* User: zhouzhou
* Date: 2018-08-28
* Time: 13:33
*/
@RestController
public class AsyncController {
@Autowired
private AsyncService asyncService;
@RequestMapping(value = "/hello",method = RequestMethod.GET)
public String testAsyncNoRetrun(){
long start = System.currentTimeMillis();
asyncService.doNoReturn();
return String.format("任务执行成功,耗时{%s}", System.currentTimeMillis() - start);
}
}

启动项目在, 浏览器中输入url :http://localhost:8080/hello

返回结果如下:

3000毫秒.接下来我们在方法上加上注解 @Async后, 重启项目, 刷新页面查看调用时间

@Async
public void doNoReturn(){
try {
// 这个方法执行需要三秒
Thread.sleep(3000);
System.out.println("方法执行结束" + new Date());
} catch (InterruptedException e) {
e.printStackTrace();
}
}

并且在主启动类上开启@EnableAsync的注解

@EnableAsync // 开启异步任务
@SpringBootApplication
public class Amqp1Application {
public static void main(String[] args) {
SpringApplication.run(Amqp1Application.class, args);
}
}

测试完成, 异步任务如此简单,就这样.

第二部分:有返回值的异步任务

返回值用Futrue变量封装起来,下面是service层的代码

@Async
public Future<String> doReturn(int i){
try {
// 这个方法需要调用500毫秒
Thread.sleep(500);
} catch (InterruptedException e) {
e.printStackTrace();
}
// 消息汇总
return new AsyncResult<>(String.format("这个是第{%s}个异步调用的证书", i));
}

读取的时候,记得要批量读取不能单独读取, 下面是controller层的代码

@GetMapping("/hi")
public Map<String, Object> testAsyncReturn() throws ExecutionException, InterruptedException {
long start = System.currentTimeMillis();
Map<String, Object> map = new HashMap<>();
List<Future<String>> futures = new ArrayList<>();
for (int i = 0; i < 10; i++) {
Future<String> future = asyncService.doReturn(i);
futures.add(future);
}
List<String> response = new ArrayList<>();
for (Future future : futures) {
String string = (String) future.get();
response.add(string);
}
map.put("data", response);
map.put("消耗时间", String.format("任务执行成功,耗时{%s}毫秒", System.currentTimeMillis() - start));
return map;
}

在浏览器输入地址:http://localhost:8080/hi

结果如下: 耗时500多毫秒的意思代表,springboot自带异步任务线程池是小于10的大小的

一定要批量读取结果, 否则不能达到异步的效果!!

1、异步方法和调用类不要在同一个类中

2、注解扫描时，要注意过滤，避免重复实例化，因为存在覆盖问题，@Async就失效了

SpringBoot异步任务, 以及带返回值的异步任务(@Async 不起作用的原因)相关推荐

springboot 的异步任务：无返回值和有返回值
在想要异步执行的方法上加上@Async注解,在controller上加上@EnableAsync,即可. 注:这里的异步方法,只能在本类之外调用,在本类调用是无效的. 无返回值的异步任务 servic ...
async js 返回值_JS异步编程 | Async / Await / Generator 实现原理解析
async/await实现在多个回调依赖的场景中,尽管Promise通过链式调用取代了回调嵌套,但过多的链式调用可读性仍然不佳,流程控制也不方便,ES7 提出的async 函数,终于让 JS 对于异 ...
C++ 多线程之带返回值的线程处理函数
写在前面: 又是学C扎扎的一天,C扎扎学起来果然扎手.如果你能坚持看到文章最后,你会发现,好吧有可能你啥也发现不了,因为后面什么也没有~~~ 目录 1. 使用 async 函数创建线程 ...
定义一个带参带返回值的方法，实现输出随机数数组
public class mains { public static void main(String[] args) { // 创建对象,对象名为hello mains hello = new ma ...
Java05-day05【方法(概述、调用过程图解)、带参方法、带返回值方法、重载、方法参数传递(基本类型、引用类型)】
java零基础入门到精通(2019版)[黑马程序员] 视频+资料:[链接:https://pan.baidu.com/s/1MdFNUADVSFf-lVw3SJRvtg 提取码:zjxs] &qu ...
android cursor 实例化,为什么Cursor放到带参数带返回值方法里就报错？
完整代码如下: 其中有大部分的代码被注释,那是可以成功运行的. 后来我想啊,游戏有好多种,但是需要统计的内容是一样的. 我就想传参然后获得返回值的方式来减少代码量啊. 但是把相关的查询代码放到带 ...
实验3.1 简单实现Intent带返回值的跳转
在这里实现的功能是当点击listview的某一子项是,启动一个确认删除相应记录的子Activity. 所以用到了带返回值的intent 父界面和子界面的前台代码 activity_main <? ...
Mysql带返回值与不带返回值的2种存储过程
过程1:带返回值: 1 drop procedure if exists proc_addNum; 2 create procedure proc_addNum (in x int,in y int, ...
php异步请求$.post,如何用PHP实现异步请求、忽略返回值
本篇文章的主要内容是用PHP实现异步请求.忽略返回值,具有一定的参考价值,有需要的朋友可以看看,希望能对你有帮助. 项目需要,场景如下: 某个条件下需要调用接口发送多个请求执行脚本,但是由于每个请求下 ...

SpringBoot异步任务, 以及带返回值的异步任务(@Async 不起作用的原因)

第一部分: 无返回值异步任务

第二部分:有返回值的异步任务

一定要批量读取结果, 否则不能达到异步的效果!!

1、异步方法和调用类不要在同一个类中

SpringBoot异步任务, 以及带返回值的异步任务(@Async 不起作用的原因)相关推荐

最新文章

热门文章