Spring里的Async注解实现异步操作
异步执行一般用来发送一些消息数据,数据一致性不要求太高的场景,对于spring来说,它把这个异步进行了封装,使用一个注解就可以实现。
用法
- 程序启动时开启@EnableAsync注解
- 建立新的类型,建立异步方法,为方法添加@Async注解
- 在业务代码中,@Autowired注入你的类型,使用它即可
Async几种方式
- 没有返回值的,不会阻塞主线程,相当于开启新线程在后台执行这个任务
@Async
public String sayHello2() throws InterruptedException {
Thread.sleep(2 * 1000);//网络连接中 。。。消息发送中。。。
return "我爱你啊!";// 调用方调用后会立即返回,所以返回null
}
- 带有返回值的,返回类型必须为Future<>,它会开启新的线程执行任务,并阻塞主线程,执行完成后把结果返回给主线程
@Async
public Future<String> asyncFunc() throws InterruptedException {
int thinking = 2;
Thread.sleep(thinking * 1000);
System.out.println("async!");
return new AsyncResult<String>("发送消息用了" + thinking + "秒");
}
调用方法
@GetMapping("/lind-demo/asyncFunc")
public void async() throws Exception {
Future<String> future = null;
future = asyncService.asyncFunc();
System.out.println(future.get());
System.out.println("主线程被阻塞执行完成");
}
执行结果
async! 发送消息用了2秒 主线程执行完成异步执行一般用来发送一些消息数据,数据一致性不要求太高的场景,对于spring来说,它把这个异步进行了封装,使用一个注解就可以实现。 用法 程序启动时开启@EnableAsync注解 建立新的类型,建立异步方法,为方法添加@Async注解 在业务代码中,@Autowired注入你的类型,使用它即可 Async几种方式 没有返回值的,不会阻塞主线程,相当于开启新线程在后台执行这个任务 @Async public String sayHello2() throws InterruptedException { Thread.sleep(2 * 1000);//网络连接中 。。。消息发送中。。。 return "我爱你啊!";// 调用方调用后会立即返回,所以返回null } 带有返回值的,返回类型必须为Future<>,它会开启新的线程执行任务,并阻塞主线程,执行完成后把结果返回给主线程 @Async public Future
