[Java知识库] SpringBoot异步Async处理

开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> Java知识库 -> SpringBoot异步Async处理 -> 正文阅读

[Java知识库]SpringBoot异步Async处理

SpringApplication开启Async

@Slf4j
@EnableAsync
@SpringBootApplication
public class CommonApplication {

    public static void main(String[] args) {
        log.info("application start...");
        SpringApplication.run(CommonApplication.class, args);
    }

}

配置线程池参数

使用spring自带线程池ThreadPoolTaskExecutor处理异步任务

@Configuration
@Slf4j
public class AsyncConfig {

    private ThreadPoolTaskExecutor taskExecutor;

    /**
     * spring 自带线程池
     * @return
     */
    @Bean("taskExecutor")
    public Executor taskExecutor(){
        ThreadPoolTaskExecutor  taskExecutor = new ThreadPoolTaskExecutor();
        // 核心线程数
        taskExecutor.setCorePoolSize(10);
        // 最大线程数
        taskExecutor.setMaxPoolSize(20);
        // 队列容量
        taskExecutor.setQueueCapacity(100);
        // 线程空闲时间
        taskExecutor.setKeepAliveSeconds(60);
        // 线程名前缀
        taskExecutor.setThreadNamePrefix("taskExecutor-");
        // 用来设置线程池关闭的时候等待所有任务都完成再继续销毁其他的Bean，这样这些异步任务的销毁就会先于Redis线程池的销毁
        taskExecutor.setWaitForTasksToCompleteOnShutdown(true);
        // 设置线程池中任务的等待时间，如果超过这个时候还没有销毁就强制销毁，以确保应用最后能够被关闭，而不是阻塞住
        taskExecutor.setAwaitTerminationSeconds(60);
        // 拒绝策略
        taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        return taskExecutor;
    }

}

编写异步逻辑

/**
 * 异步工具处理
 */
@Service
public class AsyncUtils {

    @Async("taskExecutor")
    public void doTask() throws InterruptedException {
        System.out.println("处理任务");
        Thread.sleep(10000);
    }
}

调用示例

@Service
@Slf4j
public class AsyncServiceImpl implements AsyncService {

    @Autowired
    private AsyncUtils asyncUtils;

    @Override
    public void doWork() {
        try {
            System.out.println("开始工作");
            // 调用异步方法
            asyncUtils.doTask();
            System.out.println("结束工作");
        } catch (InterruptedException e) {
            log.error("thread error");
        }
    }
}