點(diǎn)擊上方藍(lán)色字體，選擇“標(biāo)星公眾號”

優(yōu)質(zhì)文章，第一時間送達(dá)

? 作者?|??迷茫中守候

來源 |? urlify.cn/MbMN32

在后端開發(fā)中經(jīng)常遇到一些耗時或者第三方系統(tǒng)調(diào)用的情況，我們知道Java程序一般的執(zhí)行流程是順序執(zhí)行（不考慮多線程并發(fā)的情況），但是順序執(zhí)行的效率肯定是無法達(dá)到我們的預(yù)期的，這時就期望可以并行執(zhí)行，常規(guī)的做法是使用多線程或線程池，需要額外編寫代碼實(shí)現(xiàn)。在spring3.0后引入了@Async注解，使用該注解可以達(dá)到線程池的執(zhí)行效果，而且在開發(fā)上非常簡單。

一、概述

springboot是基于spring框架的，在springboot環(huán)境下演示@Async注解的使用方式。先看下該注解的定義，

@Target({ElementType.METHOD,?ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public?@interface?Async?{

????/**
?????*?A?qualifier?value?for?the?specified?asynchronous?operation(s).
?????*?May?be?used?to?determine?the?target?executor?to?be?used?when?executing?this
?????*?method,?matching?the?qualifier?value?(or?the?bean?name)?of?a?specific
?????*?{@link?java.util.concurrent.Executor?Executor}?or
?????*?{@link?org.springframework.core.task.TaskExecutor?TaskExecutor}
?????*?bean?definition.
?????*?When?specified?on?a?class?level?{@code?@Async}?annotation,?indicates?that?the
?????*?given?executor?should?be?used?for?all?methods?within?the?class.?Method?level?use
?????*?of?{@code?Async#value}?always?overrides?any?value?set?at?the?class?level.
?????*?@since?3.1.2
?????*/
????String?value()?default?"";

}

可以看到該注解只有一個屬性，那就是value，從注釋上知道value指定的是執(zhí)行該任務(wù)的線程池，也就是說我們可以使用子定義的線程池執(zhí)行我們的任務(wù)，而不是系統(tǒng)默認(rèn)的。在看該注解上的注解，

@Target({ElementType.METHOD,?ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented

也就是說該注解可以用在方法和類上。標(biāo)記在類上表示類中的所有方法都以異步方式執(zhí)行，也就是提交到線程池執(zhí)行。

二、詳述

上面簡單對@Async注解進(jìn)行了解釋，下面看用法。

1、@EnableAsync注解

在springboot中要使用@Async注解必須在springboot啟動類上使用@EnableAsync注解，開啟@Async注解的自動配置，如下，

package?com.example.demo;

import?com.example.demo.properties.ApplicationPro;
import?org.springframework.boot.SpringApplication;
import?org.springframework.boot.autoconfigure.SpringBootApplication;
import?org.springframework.boot.context.properties.ConfigurationProperties;
import?org.springframework.boot.context.properties.EnableConfigurationProperties;
import?org.springframework.scheduling.annotation.EnableAsync;
import?org.springframework.scheduling.annotation.EnableScheduling;

@SpringBootApplication
@EnableConfigurationProperties({ApplicationPro.class})
//開啟@Async注解的自動配置
@EnableAsync
public?class?DemoApplication?{

????public?static?void?main(String[]?args)?{
????????SpringApplication.run(DemoApplication.class,?args);
????}

}

只有在啟動類上使用@EnableAsync注解，@Async注解才會生效。

2、@Async注解

上面使用@EnableAsync注解已經(jīng)開啟了對@Async注解的配置，下面看具體的異步調(diào)用類，

package?com.example.demo.service;

import?com.example.demo.Student;
import?org.springframework.scheduling.annotation.Async;
import?org.springframework.scheduling.annotation.AsyncResult;
import?org.springframework.stereotype.Service;

import?java.util.concurrent.Future;

@Service
@Async
public?class?AsyncService?{
????public?Future?get(){
????????Student?stu=new?Student("1","3");
????????try?{
????????????Thread.sleep(10000l);
????????}?catch?(InterruptedException?e)?{
????????????e.printStackTrace();
????????}
????????return?AsyncResult.forValue(stu);
????}

????public?void??executeRemote(){
????????try?{
????????????Thread.sleep(10000l);
????????}?catch?(InterruptedException?e)?{
????????????e.printStackTrace();
????????}
????}
}

首先，要使該類讓spring管理必須使用@Service注解（或其他注解也可以），然后在類上標(biāo)記@Async注解，前面說過@Async注解可以在方法或類上使用，在類上使用則表示類中的所有方法均使用異步執(zhí)行的方式。異步執(zhí)行類中有兩個方法，每個方法為了演示執(zhí)行的耗時操作均睡眠10s。這兩個方法一個是有返回值的，另一個是無返回值的，重點(diǎn)看有返回值的，

public?Future?get(){
????????Student?stu=new?Student("1","3");
????????try?{
????????????Thread.sleep(10000l);
????????}?catch?(InterruptedException?e)?{
????????????e.printStackTrace();
????????}
????????return?AsyncResult.forValue(stu);
????}

為什么方法的返回值是Future，在@Async注釋上有下面這句話，

從上面的注解正好可以說明返回Future是沒問題，但是我們的方法就是一個普通的方法，要怎么才能返回Future類那，不慌，spring針對@Async注解提供了AsyncResult類，從類名就知道該類就是為了@Async注解準(zhǔn)備的，

使用其中的forValue方法，便可以返回一個帶有泛型的Future類了。

看下測試類，

package?com.example.demo.controller;

import?com.example.demo.Student;
import?com.example.demo.service.AsyncService;
import?org.springframework.beans.factory.annotation.Autowired;
import?org.springframework.stereotype.Controller;
import?org.springframework.web.bind.annotation.RequestMapping;
import?org.springframework.web.bind.annotation.ResponseBody;

import?java.util.concurrent.ExecutionException;
import?java.util.concurrent.Future;
@Controller
@RequestMapping("async")
public?class?ControllerAsyncTest?{
????@Autowired
????private?AsyncService?asyncService;
????@RequestMapping("/test")
????@ResponseBody
????public?Student?get(){
????????try?{
????????long?start=System.currentTimeMillis();????????//調(diào)用帶有返回值的get方法
????????Future?result=asyncService.get();????????//調(diào)用無返回值的executeRemote方法
????????asyncService.executeRemote();
????????
????????Student?student=result.get();
????????long?end=System.currentTimeMillis();
????????System.out.println("執(zhí)行時間："+(end-start));
????????return??student;
????????}?catch?(InterruptedException?e)?{
????????????e.printStackTrace();
????????}?catch?(ExecutionException?e)?{
????????????e.printStackTrace();
????????}
????????return?null;
????}
}

測試類就是一個簡單的controller，調(diào)用了get和executeRemote方法，這兩個方法分別會睡眠10s，而且get會有返回值，下面看是否可以拿到get的返回值，并看下調(diào)用這兩個方法的時間，

可以成功拿到返回值，看執(zhí)行時間，

2020-12-12?21:37:43.556??INFO?11780?---?[nio-8080-exec-1]?o.s.web.servlet.DispatcherServlet????????:?Completed?initialization?in?5?ms
執(zhí)行時間：10006

執(zhí)行時間是10006ms，也就是10s多，按照上面的分析兩個方法分別睡眠了10s，如果同步執(zhí)行那肯定是20s，把@Async注解去掉看執(zhí)行時間，

2020-12-12?21:41:07.840??INFO?11584?---?[nio-8080-exec-1]?o.s.web.servlet.DispatcherServlet????????:?Completed?initialization?in?5?ms
執(zhí)行時間：20001

執(zhí)行時間是20001ms，算上兩個方法睡眠的時間，和測試類本身的時間，20001ms是沒錯的。從這里可以看出@Async注解的作用，把每個方法當(dāng)作任務(wù)提交給了線程池，提高了任務(wù)執(zhí)行的時間。

另外，在獲取異步的執(zhí)行結(jié)果使用了下面的方法，

Future?result=asyncService.get();
asyncService.executeRemote();
//獲得執(zhí)行結(jié)果
Student?student=result.get();

由于在主線程要獲得任務(wù)的執(zhí)行結(jié)果，使用Future類的get方法獲得結(jié)果，該結(jié)果需要等到任務(wù)執(zhí)行完以后才可以獲得。

三、總結(jié)

本文講解了異步調(diào)用@Async注解的使用，

1、使用@EnableAsync注解開啟對@Async注解的支持；

2、在類或方法上使用@Async注解；

粉絲福利：Java從入門到入土學(xué)習(xí)路線圖

???

?長按上方微信二維碼?2 秒

感謝點(diǎn)贊支持下哈?

springboot：異步調(diào)用@Async

一、概述

二、詳述

1、@EnableAsync注解

2、@Async注解

三、總結(jié)

一、概述

1、@EnableAsync注解

2、@Async注解