Spring Boot 项目中如何使用异步任务

前置知识：

同步任务：

• 同步任务是在单线程中按顺序执行，每次只有一个任务在执行，不会引发线程安全和数据一致性等并发问题

• 同步任务需要等待任务执行完成后才能执行下一个任务，无法同时处理多个任务，响应慢，影响用户体验

异步任务：

• 异步任务是在多线程中同时执行，多个任务可以并发执行，同时处理多个请求，响应快，资源利用率高，用户体验好

• 异步任务需要创建额外的线程来执行任务操作，可以使用线程池技术，灵活配置线程资源，以提高系统的资源利用率

SpringBoot实现异步任务，提高系统的并发性能和用户体验

步骤：

1. 创建线程池配置类

/**
 * 线程池配置类
 */
@Configuration
@EnableAsync //  启用异步任务
public class ThreadPoolConfig {

    @Bean
    public Executor taskExecutor() {
        // 定义线程池，使用Spring提供的ThreadPoolTaskExecutor
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(10); // 核心线程数
        executor.setMaxPoolSize(20); // 最大线程数
        executor.setQueueCapacity(50); // 缓冲队列大小
        executor.setKeepAliveSeconds(60); // 线程的空闲时间
        executor.setThreadNamePrefix("AsyncTaskExecutor-"); // 线程前缀
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); // 拒绝处理策略，交由调用方线程运行
        executor.initialize(); // 初始化
        return executor;
    }

}

        2. 创建异步任务，使用@Async注解标注

@Component
public class AsyncTask {

    @Async // 表示该方法是一个异步任务
    public void doTask() {
        System.out.println("异步任务--------" + Thread.currentThread().getName());
    }
}

        3.测试

@SpringBootTest
public class AsyncTest {

    @Resource
    private AsyncTask asyncTask;

    @Test
    public void test() {
        System.out.println("主线程---------" + Thread.currentThread().getName());
        asyncTask.doTask();
    }
}

案例：

Spring Boot 项目中如何使用异步任务(案例)