乐趣区

关于springboot:SpringBoot执行异步任务Async介绍

jiezi

前言

本篇文章的代码示例已放到 github 上，Git 地址为：advance（记录每一个学习过程），大家把代码下载下来之后，全局搜寻一些要害代码，即可找到该文章的源码。

大家感觉有用的话，麻烦点个 star👍再走呗！

应用场景

当咱们在应用 SpringBoot 进行开发的时候，可能会遇到一些执行异步工作的场景，如果每次执行这些异步工作都去新建一个异步线程来执行的话，那代码就太冗余了。幸好 SpringBoot 给咱们提供了 Async 的注解，让咱们可能很轻松地对这些异步工作进行执行。

应用示例

在启动类上应用 @EnableAsync 注解，示意开启异步工作 

@EnableAsync
@SpringBootApplication
public class AsycnDemoApplication {public static void main(String[] args) {SpringApplication.run(AsycnDemoApplication.class, args);
    }

}

将须要执行的异步办法所在的类，退出到 Spring 的容器中，能够应用 @Component 注解 

@Component
public class AsyncComponent {}

在须要异步执行的办法上，退出 @Async 注解 

@Component
public class AsyncComponent {
    @Async
    public void async(String str){System.out.println("输出的内容是" + str + "，异步工作正在休眠 5 秒..");
        try {TimeUnit.SECONDS.sleep(5);
        } catch (InterruptedException e) {System.out.println("休眠失败");
        }
        System.out.println("输出的内容是" + str + ", 异步工作执行完结");
    }
}

在其余须要调用的中央，将这个异步办法所在的类进行注入，而后调用 

@Component
public class LineRunner implements CommandLineRunner {
    @Autowired
    private AsyncComponent asyncComponent;

    @Override
    public void run(String... args) throws Exception {System.out.println("主线程开始");
        asyncComponent.async("明天不下班，好耶");
        asyncComponent.selfAsync();
        System.out.println("主线程完结");
    }
}

执行后果

自定义异步调用的线程池

SpringBoot 默认会应用 SimpleAsyncTaskExecutor 线程池，这个不是真的线程池，不会重用线程，每次调用都会新建一个线程进去，用完之后就回收掉，没起到反复利用的作用。并发量太大的话，可能会有内存溢出的危险。

因而，更加举荐开发者对异步调用的线程池进行自定义。

自定义异步线程池 

@Configuration
public class ExecutorsAsyncConfig {@Bean(name = "asyncConfig")
    public Executor asyncConfig(){ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        // 设置外围线程数
        executor.setCorePoolSize(5);
        // 设置最大线程数
        executor.setMaxPoolSize(50);
        // 设置缓存的队列
        executor.setQueueCapacity(1000);
        // 设置闲暇线程的超时工夫
        executor.setKeepAliveSeconds(1000 * 5);
        // 设置线程名称的前缀
        executor.setThreadNamePrefix("async-config-");
        executor.initialize();
        return executor;
    }
}

编写自定义的异步办法，其实也就就是在 @Async 的注解上加了线程池的 bean 名称。

@Async("asyncConfig")
public void selfAsync(){System.out.println("我是自定义异步线程，线程池名称:" + Thread.currentThread().getName());
    try {TimeUnit.SECONDS.sleep(5);
    } catch (InterruptedException e) {System.out.println("休眠失败");
    }
    System.out.println("自定义异步线程休眠完结");
}

调用自定义的异步办法 

asyncComponent.selfAsync();

执行后果

Async 生效场景（注意事项）

  1. 调用办法和异步办法在同一个类中，会导致 Async 生效。
  2. 异步办法应用了 static 进行润饰，会导致 Async 生效。
退出移动版