【thread】优雅的使用线程池

原创

无敌小菜鸟

发布于 2022-06-11 09:46:47

4680

发布于 2022-06-11 09:46:47

文章被收录于专栏：搬砖笔记搬砖笔记

最近在优化项目的多线程的使用方法，以前都是显示的使用线程启动，造成启动的线程多了，比较占用系统的资源，随即着手优化了下项目的线程使用方法。

一、老式方法

都是显式的调用，并且阿里巴巴开发手册并不推荐这样使用。

        //新建线程并执行任务类
        new Thread(() -> {
            System.out.println(Thread.currentThread().getName() + "：异步任务");
        }).start();

二、优化方法

创建线程池配置

@Configuration
public class AsyncConfig {

    private static final int MAX_POOL_SIZE = 50;

    private static final int CORE_POOL_SIZE = 20;

    @Bean("asyncTaskExecutor")
    public AsyncTaskExecutor asyncTaskExecutor() {
        ThreadPoolTaskExecutor asyncTaskExecutor = new ThreadPoolTaskExecutor();
        asyncTaskExecutor.setMaxPoolSize(MAX_POOL_SIZE);
        asyncTaskExecutor.setCorePoolSize(CORE_POOL_SIZE);
        asyncTaskExecutor.setThreadNamePrefix("async--pool-");
        asyncTaskExecutor.initialize();
        return asyncTaskExecutor;
    }
}

启用异步支持

启动类上添加@EnableAsync注解

@SpringBootApplication
@EnableAsync
public class SpringbootAsyncApplication {

    public static void main(String[] args) {
        SpringApplication.run(SpringbootAsyncApplication.class, args);
    }

}

在其它类中使用线程池

先注入线程池类，再使用线程类的submit方法即可

@Autowired
private AsyncTaskExecutor asyncTaskExecutor;


@GetMapping("/")
public String test() {
    // 使用异步线程池 线程
    asyncTaskExecutor.submit(() -> {
        log.info(Thread.currentThread().getName() + "asyncTaskExecutor");
    });
    return "ok";
}

这样我们就使用上了线程池的配置，也不用显式的去使用线程池了。