共计 2062 个字符,预计需要花费 6 分钟才能阅读完成。
前言
本篇文章的代码示例已放到 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 生效场景(注意事项)
- 调用办法和异步办法在同一个类中,会导致 Async 生效。
- 异步办法应用了 static 进行润饰,会导致 Async 生效。
正文完
发表至: springboot
2023-09-23