Spring源码学习之：@async 方法上添加该注解实现异步调用的原理

• Spring源码学习之：@async 方法上添加该注解实现异步调用的原理

  在咱们使用spring框架的过程当中，在不少时候咱们会使用@async注解来异步执行某一些方法，提升系统的执行效率。今天咱们来探讨下 spring 是如何完成这个功能的。
  
      spring 在扫描bean的时候会扫描方法上是否包含@async的注解，若是包含的，spring会为这个bean动态的生成一个子类，咱们称之为代理类(?)， 代理类是继承咱们所写的bean的，而后把代理类注入进来，那此时，在执行此方法的时候，会到代理类中，代理类判断了此方法须要异步执行，就不会调用父类 (咱们本来写的bean)的对应方法。spring本身维护了一个队列，他会把须要执行的方法，放入队列中，等待线程池去读取这个队列，完成方法的执行， 从而完成了异步的功能。咱们能够关注到再配置task的时候，是有参数让咱们配置线程池的数量的。由于这种实现方法，因此在同一个类中的方法调用，添加@async注解是失效的！，缘由是当你在同一个类中的时候，方法调用是在类体内执行的，spring没法截获这个方法调用。
  
      那在深刻一步，spring为咱们提供了AOP，面向切面的功能。他的原理和异步注解的原理是相似的，spring在启动容器的时候，会扫描切面所定义的 类。在这些类被注入的时候，所注入的也是代理类，当你调用这些方法的时候，本质上是调用的代理类。经过代理类再去执行父类相对应的方法，那spring只 须要在调用以前和以后执行某段代码就完成了AOP的实现了！
  
     那最后咱们还有一个问题，spring是如何动态的生成某一个类的子类的？代理类？

•  

  @RunWith(SpringJUnit4ClassRunner.class)
  @ContextConfiguration({"classpath:/applicationContext.xml"})
  public class TestAsync {
      @Autowired
      private TestAsyncBean testAsyncBean;
      @Test
      public void test_sayHello1() throws InterruptedException, ExecutionException {
          Future<String> future = null;
          System.out.println("你不爱我了么?");
          future = testAsyncBean.sayHello1();
          System.out.println("你竟无话可说, 咱们分手吧。。。");
          Thread.sleep(3 * 1000);// 不让主进程过早结束
          System.out.println(future.get());
      }
  }

   

   

   

  简单介绍：

   

  Spring为任务调度与异步方法执行提供了注解支持。经过在方法上设置@Async注解，可以使得方法被异步调用。也就是说调用者会在调用时当即返回，而被调用方法的实际执行是交给Spring的TaskExecutor来完成。

   

   

   

  开启@Async注解：

  <task:annotation-driven executor="annotationExecutor" />
  <!-- 支持 @Async 注解 -->
  <task:executor id="annotationExecutor" pool-size="20"/>

  同时加入<context:component-scan />扫描注解。

  栗子：

  为了比较，先来一个同步调用：

   

  @Component
  public class TestAsyncBean {
      public void sayHello4() throws InterruptedException {
          Thread.sleep(2 * 1000);//网络链接中 。。。消息发送中。。。
          System.out.println("我爱你啊!");
  }

   

  @RunWith(SpringJUnit4ClassRunner.class)
  @ContextConfiguration({"classpath:/applicationContext.xml"})
  public class TestAsync {
      @Test
      public void test_sayHello4() throws InterruptedException, ExecutionException {
          System.out.println("你不爱我了么?");
          testAsyncBean.sayHello4();
          System.out.println("回的这么慢, 你确定不爱我了, 咱们仍是分手吧。。。");
          Thread.sleep(3 * 1000);// 不让主进程过早结束
      }
  }

  输出结果：

  你不爱我了么?
  我爱你啊!
  回的这么慢, 你确定不爱我了, 咱们仍是分手吧。。。

   

  同步调用会按代码顺序依次进行下去，若是哪里须要等待，那么就阻塞在那里，再也不向下继续进行。

   

  使用@Async的异步调用：

   

  @Component
  public class TestAsyncBean {
      @Async
      public void sayHello3() throws InterruptedException {
          Thread.sleep(2 * 1000);//网络链接中 。。。消息发送中。。。
          System.out.println("我爱你啊!");
      }
  }

   

  @RunWith(SpringJUnit4ClassRunner.class)
  @ContextConfiguration({"classpath:/applicationContext.xml"})
  public class TestAsync {
      @Autowired
      private TestAsyncBean testAsyncBean;
      @Test
      public void test_sayHello3() throws InterruptedException, ExecutionException {
          System.out.println("你不爱我了么?");
          testAsyncBean.sayHello3();
          System.out.println("你竟无话可说, 咱们分手吧。。。");
          Thread.sleep(3 * 1000);// 不让主进程过早结束
      }
  }

  输出结果：

  你不爱我了么?
  你竟无话可说, 咱们分手吧。。。
  我爱你啊!

   

  异步调用，经过开启新的线程来执行调用的方法，不影响主线程。异步方法实际的执行交给了Spring的TaskExecutor来完成。

   

  上面这种方式是没有返回值的，下面尝试有返回值的异步调用：

   

  @Component
  public class TestAsyncBean {
      @Async
      public String sayHello2() throws InterruptedException {
          Thread.sleep(2 * 1000);//网络链接中 。。。消息发送中。。。
          return "我爱你啊!";// 调用方调用后会当即返回,因此返回null
      }
  }

   

  @RunWith(SpringJUnit4ClassRunner.class)
  @ContextConfiguration({"classpath:/applicationContext.xml"})
  public class TestAsync {
      @Autowired
      private TestAsyncBean testAsyncBean;
      @Test
      public void test_sayHello2() throws InterruptedException, ExecutionException {
          System.out.println("你不爱我了么?");
          System.out.println(testAsyncBean.sayHello2());
          System.out.println("你说的啥? 咱们仍是分手吧。。。");
          Thread.sleep(3 * 1000);// 不让主进程过早结束
      }
  }

  输出结果：

  你不爱我了么?
  null
  你说的啥? 咱们仍是分手吧。。。

   

  经过直接获取返回值得方式是不行的，这里就须要用到异步回调，异步方法返回值必须为Future<>，就像Callable与Future。

   

  下面经过AsyncResult<>来得到异步调用的返回值：

  @Component
  public class TestAsyncBean {
      @Async
      public Future<String> sayHello1() throws InterruptedException {
          int thinking = 2;
          Thread.sleep(thinking * 1000);//网络链接中 。。。消息发送中。。。
          System.out.println("我爱你啊!");
          return new AsyncResult<String>("发送消息用了"+thinking+"秒");
      }
  }

  输出结果：

  你不爱我了么?
  你竟无话可说, 咱们分手吧。。。
  我爱你啊!
  发送消息用了2秒