SpringBoot 多线程

1. 启动类开启多线程支持

使用 @EnableAsync 来开启 Springboot 对于异步任务的支持

@SpringBootApplication
@EnableAsync // 开启多线程
public class SpringBootApplication {
    public static void main(String[] args) {
        SpringApplication.run(SpringBootApplication.class, args);
    }
}

2. 添加配置类

配置类实现接口AsyncConfigurator，返回一个ThreadPoolTaskExecutor线程池对象

ThredPoolTaskExcutor的处理流程 :

当池子大小小于corePoolSize，就新建线程，并处理请求

当池子大小等于 corePoolSize，把请求放入 workQueue 中，池子里的空闲线程就去workQueue 中取任务并处理

当 workQueue 放不下任务时，就新建线程入池，并处理请求，如果池子大小撑到了 maximumPoolSize，就用 RejectedExecutionHandler 来做拒绝处理

当池子的线程数大于 corePoolSize 时，多余的线程会等待 keepAliveTime 长时间，如果无请求可处理就自行销毁

@Configuration
@EnableAsync
public class TaskExecutorConfig implements AsyncConfigurer {

    @Override
    @Bean
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor threadPool = new ThreadPoolTaskExecutor();
        //设置核心线程数
        threadPool.setCorePoolSize(10);
        //设置最大线程数
        threadPool.setMaxPoolSize(100);
        //线程池所使用的缓冲队列
        threadPool.setQueueCapacity(10);
        //等待任务在关机时完成--表明等待所有线程执行完
        threadPool.setWaitForTasksToCompleteOnShutdown(true);
        // 等待时间 （默认为0，此时立即停止），并没等待xx秒后强制停止
        threadPool.setAwaitTerminationSeconds(60);
        //  线程名称前缀
        threadPool.setThreadNamePrefix("Derry-Async-");
        // 初始化线程
        threadPool.initialize();
        return threadPool;
    }

    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return null;
    }
}

3. @Async 注解

通过 @Async 注解表明该方法是异步方法，如果注解在类上，那表明这个类里面的所有方法都是异步的

@Service
public class AsyncTaskService {
    @Async
    public void executeAsyncTask(int i) {
        System.out.println("线程" + Thread.currentThread().getName() + " 执行异步任务：" + i);
    }
}

测试

@RunWith (SpringRunner.class)
@SpringBootTest
public class SpringbootLearnApplicationTests {
 @Autowired
 private AsyncTaskService asyncTaskService;

 @Test
 public void threadTest() {
     for (int i = 0; i < 20; i++) {
         asyncTaskService.executeAsyncTask(i);
     }
 }

}

执行结果：

线程Derry-Async-1 执行异步任务：0
线程Derry-Async-1 执行异步任务：10
线程Derry-Async-1 执行异步任务：11
线程Derry-Async-2 执行异步任务：1
线程Derry-Async-6 执行异步任务：5
线程Derry-Async-6 执行异步任务：14
线程Derry-Async-6 执行异步任务：15
线程Derry-Async-6 执行异步任务：16
线程Derry-Async-7 执行异步任务：6
线程Derry-Async-6 执行异步任务：17
线程Derry-Async-6 执行异步任务：19
线程Derry-Async-3 执行异步任务：2
线程Derry-Async-9 执行异步任务：8
线程Derry-Async-5 执行异步任务：4
线程Derry-Async-2 执行异步任务：13
线程Derry-Async-8 执行异步任务：7
线程Derry-Async-1 执行异步任务：12
线程Derry-Async-10 执行异步任务：9
线程Derry-Async-4 执行异步任务：3
线程Derry-Async-7 执行异步任务：18