Spring实现异步线程Async

Spring实现异步线程Async

配置文件

/config/ThreadToolConfig

import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.AsyncConfigurer;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.Executor;

/**
 * @author 曳戈泰尔
 * @date 2021-09-15
 * @describe 配置异步多线程的线程池
 */
@Configuration
@EnableAsync
public class ThreadToolConfig implements AsyncConfigurer {

    // 声明线程池
    @Override
    public Executor getAsyncExecutor(){

        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();

        // 核心线程数：5
        executor.setCorePoolSize(10);
        // 最大线程数：5
        executor.setMaxPoolSize(10);
        // 缓冲队列：500，用来缓冲执行任务的队列
        executor.setQueueCapacity(500);
        // 允许线程的空闲时间：60s
        executor.setKeepAliveSeconds(10);
        // 线程池名的前缀：方便定位处理任务的线程池
        executor.setThreadNamePrefix("Async-");
        // 加载
        executor.initialize();

        return executor;
    }

    // 异常处理
    @Override
    public SimpleAsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler(){
        /**
        * ......
        */
    }
}

使用方式

在方法上引入注解”@Async”，如：

@Async
public void xxxxx() {

    ......

}