我们在工作开发中经常可以不需要同步的任务,会降低性能,这个时候可以使用mq,也可以使用@Async异步注解,我们需要一下配置:
1.在启动类加上@EnableAsync注解
@SpringCloudApplication
@EnableAsync
public class DabaimaoApplication
{
/**
* 开启openfeign负载均衡
* */
@Bean
@LoadBalanced
public RestTemplate restTemplate(){
return new RestTemplate();
}
public static void main(String[] args)
{
SpringApplication.run(DabaimaoApplication.class, args);
}
}
2.在Bean中配置一个线程池
@Configuration
@EnableAsync
public class AsyncConfig {
@Bean("asyncExecutor")
public TaskExecutor asyncExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(5); // 线程池核心线程数
executor.setMaxPoolSize(10); // 线程池最大线程数
executor.setQueueCapacity(20); // 队列容量
executor.setThreadNamePrefix("Async-"); // 线程名前缀
executor.initialize(); // 初始化
return executor;
}
// 其他配置(如果有)
}
3.在对应的方法中加上注解
@Service
public class MyService {
@Async("asyncExecutor") // 指定使用哪个线程池
public void asyncMethod() {
// 异步执行的逻辑
}
}
4.这样的话调用这个方法会默认从配置的线程池创建线程异步执行