通过线程池开启异步任务 @Async

news2024/11/13 20:27:21

同步任务：

同步任务是在单线程中按顺序执行，每次只有一个任务在执行，不会引发线程安全和数据一致性等并发问题
同步任务需要等待任务执行完成后才能执行下一个任务，无法同时处理多个任务，响应慢，影响用户体验

异步任务：

异步任务是在多线程中同时执行，多个任务可以并发执行，同时处理多个请求，响应快，资源利用率高，用户体验好
异步任务需要创建额外的线程来执行任务操作，可以使用线程池技术，灵活配置线程资源，以提高系统的资源利用率

首次，创建线程池：

@Configuration
@EnableAsync //启用异步任务
public class ThreadPoolConfig {

    @Bean
    public Executor taskPoolConfig(){
        //定义线程池，使用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;
    }
}

创建异步任务：

@Component
public class AsyncTask {

    public void doTask(){
        System.out.println("异步任务……" + Thread.currentThread().getName());
    }
}

编写测试类：

@SpringBootTest
public class AsyncTest {
    @Resource
    private AsyncTask asyncTask;

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

执行测试类代码：

可以看出以上并没有使用线程池，因为线程池中的线程，我们设置了默认前缀 AsyncTaskExecutor-

下面添加注解：@Async

@Component
public class AsyncTask {

    @Async
    public void doTask(){
        System.out.println("异步任务……" + Thread.currentThread().getName());
    }
}

再次执行测试类：