zoukankan      html  css  js  c++  java
  • Spring里的Async注解实现异步操作

    异步执行一般用来发送一些消息数据,数据一致性不要求太高的场景,对于spring来说,它把这个异步进行了封装,使用一个注解就可以实现。

    用法

    1. 程序启动时开启@EnableAsync注解
    2. 建立新的类型,建立异步方法,为方法添加@Async注解
    3. 在业务代码中,@Autowired注入你的类型,使用它即可

    我们可以关注到在配置task的时候,是有参数让我们配置线程池的数量的。因为这种实现方法,所以在同一个类中的方法调用,添加@async注解是失效的!,原因是当你在同一个类中的时候,方法调用是在类体内执行的,spring无法截获这个方法调用.

    Async几种方式

    1. 没有返回值的,不会阻塞主线程,相当于开启新线程在后台执行这个任务
        @Async
        public String sayHello2() throws InterruptedException {
            Thread.sleep(2 * 1000);//网络连接中 。。。消息发送中。。。
            return "我爱你啊!";// 调用方调用后会立即返回,所以返回null
        }
    
    1. 带有返回值的,返回类型必须为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秒
    主线程执行完成
    
  • 相关阅读:
    service
    Specify the input method type
    添加机型
    高数公式
    MacOS 常用终端命令大全
    Linux-常用命令大全
    Mac系统下利用ADB命令使用
    iOS工程师学习Android开发----AndroidStudio环境准备
    封装socket 到vue2.x 使用
    记录一次因为OutOfMemoryError而发现的Excel文件导入慢的优化思路
  • 原文地址:https://www.cnblogs.com/lori/p/10789216.html
Copyright © 2011-2022 走看看