异步调用Async

妖狐艹你老母 2022-05-30 05:54 263阅读 0赞

什么是异步调用？

异步调用是相对于同步调用而言的，同步调用是指程序按预定顺序一步步执行，每一步必须等到上一步执行完后才能执行，异步调用则无需等待上一步程序执行完即可执行。

如何实现异步调用？

多线程，这是很多人第一眼想到的关键词，没错，多线程就是一种实现异步调用的方式。

在非spring目项目中我们要实现异步调用的就是使用多线程方式，可以自己实现Runable接口或者集成Thread类，或者使用jdk1.5以上提供了的Executors线程池。

StrngBoot中则提供了很方便的方式执行异步调用。

按照官方示例开撸

代码入下

maven依赖：

**\[java\]**  [view plain][]  [copy][view plain]

1.  <parent>  
2.      <groupId>org.springframework.boot</groupId>  
3.      <artifactId>spring-boot-starter-parent</artifactId>  
4.      <version>1.5.3.RELEASE</version>  
5.  </parent>  
6.  <dependencies>  
7.      <dependency>  
8.          <groupId>org.springframework.boot</groupId>  
9.          <artifactId>spring-boot-starter-web</artifactId>  
10.     </dependency>  
11. </dependencies>

启动类：添加@EnableAsync注解

**\[java\]**  [view plain][]  [copy][view plain]

1.  @SpringBootApplication  
2.  @EnableAsync  
3.  public class Application\{  
4.    
5.      public static void main(String\[\] args) \{  
6.          SpringApplication.run(Application.class, args);  
7.      \}  
8.  \}

Controller

只需在需要异步执行方法上添加@Async注解

**\[java\]**  [view plain][]  [copy][view plain]

1.  @RestController  
2.  @RequestMapping("")  
3.  public class AsyncTaskController \{  
4.        
5.      @RequestMapping("")  
6.      public String doTask() throws InterruptedException\{  
7.          long currentTimeMillis = System.currentTimeMillis();  
8.          this.task1();  
9.          this.task2();  
10.         this.task3();  
11.         long currentTimeMillis1 = System.currentTimeMillis();  
12.         return "task任务总耗时:"\+(currentTimeMillis1-currentTimeMillis)+"ms";  
13.     \}  
14.       
15.     @Async  
16.     public void task1() throws InterruptedException\{  
17.         long currentTimeMillis = System.currentTimeMillis();  
18.         Thread.sleep(1000);  
19.         long currentTimeMillis1 = System.currentTimeMillis();  
20.         System.out.println("task1任务耗时:"\+(currentTimeMillis1-currentTimeMillis)+"ms");  
21.     \}  
22.       
23.     @Async  
24.     public void task2() throws InterruptedException\{  
25.         long currentTimeMillis = System.currentTimeMillis();  
26.         Thread.sleep(2000);  
27.         long currentTimeMillis1 = System.currentTimeMillis();  
28.         System.out.println("task2任务耗时:"\+(currentTimeMillis1-currentTimeMillis)+"ms");  
29.     \}  
30.     @Async  
31.     public void task3() throws InterruptedException\{  
32.         long currentTimeMillis = System.currentTimeMillis();  
33.         Thread.sleep(3000);  
34.         long currentTimeMillis1 = System.currentTimeMillis();  
35.         System.out.println("task3任务耗时:"\+(currentTimeMillis1-currentTimeMillis)+"ms");  
36.     \}  
37. \}

main函数运行spirngboot项目，启动完成后浏览器访问：

http://localhost:8080/

控制台：

**\[html\]**  [view plain][]  [copy][view plain]

1.  task1任务耗时:1012ms  
2.  task2任务耗时:2009ms  
3.  task3任务耗时:3004ms

等了一段浏览器时候输出入下：

**\[html\]**  [view plain][]  [copy][view plain]

1.  task任务总耗时:6002ms

异步并没有执行！

难道是代码写错了？反复检查了好几遍，并没有发现什么明显错误，想起spring对@Transactional注解时也有类似问题，spring扫描时具有@Transactional注解方法的类时，是生成一个代理类，由代理类去开启关闭事务，而在同一个类中，方法调用是在类体内执行的，spring无法截获这个方法调用。

豁然开朗，将异步任务单独放到一个类中，调整代码入下：

Controller

**\[java\]**  [view plain][]  [copy][view plain]

异步任务类

**\[java\]**  [view plain][]  [copy][view plain]

1.  @Component  
2.  public class AsyncTask \{  
3.        
4.      @Async  
5.      public void task1() throws InterruptedException\{  
6.          long currentTimeMillis = System.currentTimeMillis();  
7.          Thread.sleep(1000);  
8.          long currentTimeMillis1 = System.currentTimeMillis();  
9.          System.out.println("task1任务耗时:"\+(currentTimeMillis1-currentTimeMillis)+"ms");  
10.     \}  
11.       
12.     @Async  
13.     public void task2() throws InterruptedException\{  
14.         long currentTimeMillis = System.currentTimeMillis();  
15.         Thread.sleep(2000);  
16.         long currentTimeMillis1 = System.currentTimeMillis();  
17.         System.out.println("task2任务耗时:"\+(currentTimeMillis1-currentTimeMillis)+"ms");  
18.     \}  
19.     @Async  
20.     public void task3() throws InterruptedException\{  
21.         long currentTimeMillis = System.currentTimeMillis();  
22.         Thread.sleep(3000);  
23.         long currentTimeMillis1 = System.currentTimeMillis();  
24.         System.out.println("task3任务耗时:"\+(currentTimeMillis1-currentTimeMillis)+"ms");  
25.     \}  
26. \}

控制台：

**\[html\]**  [view plain][]  [copy][view plain]

1.  task1任务耗时:1012ms  
2.  task2任务耗时:2009ms  
3.  task3任务耗时:3004ms

访问浏览器结果入下：

**\[html\]**  [view plain][]  [copy][view plain]

1.  task任务总耗时:19ms

异步调用成功！

如何知道三个异步任务什么时候执行完，执行的结果怎样呢？可以采用添加Fature回调方式判断

代码入下：

异步任务类

**\[java\]**  [view plain][]  [copy][view plain]

1.  @Component  
2.  public class AsyncTask \{  
3.        
4.      @Async  
5.      public Future<String> task1() throws InterruptedException\{  
6.          long currentTimeMillis = System.currentTimeMillis();  
7.          Thread.sleep(1000);  
8.          long currentTimeMillis1 = System.currentTimeMillis();  
9.          System.out.println("task1任务耗时:"\+(currentTimeMillis1-currentTimeMillis)+"ms");  
10.         return new AsyncResult<String>("task1执行完毕");  
11.     \}  
12.       
13.     @Async  
14.     public Future<String> task2() throws InterruptedException\{  
15.         long currentTimeMillis = System.currentTimeMillis();  
16.         Thread.sleep(2000);  
17.         long currentTimeMillis1 = System.currentTimeMillis();  
18.         System.out.println("task2任务耗时:"\+(currentTimeMillis1-currentTimeMillis)+"ms");  
19.         return new AsyncResult<String>("task2执行完毕");  
20.     \}  
21.     @Async  
22.     public Future<String> task3() throws InterruptedException\{  
23.         long currentTimeMillis = System.currentTimeMillis();  
24.         Thread.sleep(3000);  
25.         long currentTimeMillis1 = System.currentTimeMillis();  
26.         System.out.println("task3任务耗时:"\+(currentTimeMillis1-currentTimeMillis)+"ms");  
27.         return new AsyncResult<String>("task3执行完毕");  
28.     \}  
29. \}

Controller

**\[java\]**  [view plain][]  [copy][view plain]

1.  @RequestMapping("")  
2.  @RestController  
3.  public class AsyncTaskController \{  
4.        
5.      @Autowired  
6.      private AsyncTask asyncTask;  
7.        
8.      @RequestMapping("")  
9.      public String doTask() throws InterruptedException\{  
10.         long currentTimeMillis = System.currentTimeMillis();  
11.         Future<String> task1 = asyncTask.task1();  
12.         Future<String> task2 = asyncTask.task2();  
13.         Future<String> task3 = asyncTask.task3();  
14.         String result = null;  
15.         for (;;) \{  
16.             if(task1.isDone() && task2.isDone() && task3.isDone()) \{  
17.                 // 三个任务都调用完成，退出循环等待  
18.                 break;  
19.             \}  
20.             Thread.sleep(1000);  
21.         \}  
22.         long currentTimeMillis1 = System.currentTimeMillis();  
23.         result = "task任务总耗时:"\+(currentTimeMillis1-currentTimeMillis)+"ms";  
24.         return result;  
25.     \}  
26. \}

控制台输出：

**\[html\]**  [view plain][]  [copy][view plain]

1.  task1任务耗时:1000ms  
2.  task2任务耗时:2001ms  
3.  task3任务耗时:3001ms

浏览器输出：

**\[html\]**  [view plain][]  [copy][view plain]

1.  <span style="font-family:Simsun;font-size:14px;">task任务总耗时:4015ms</span>

异步调用成功，并且在所有任务都完成时程序才返回了结果！

[view plain]: http://blog.csdn.net/v2sking/article/details/72795742#