springboot中的@Async多线程注解

发布时间:2023-12-21 10:30

在@Async注解之前,使用多线程需要使用JDK的原生方法,非常麻烦,当有了@Async之后就比较简单了。

springboot项目中使用的demo:

1、创建线程池,配置类线程池的Bean


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

import java.util.concurrent.ThreadPoolExecutor;


@EnableAsync
@Configuration
public class AsyncConfig {
    @Bean("asyncExecutor")
    public ThreadPoolTaskExecutor asyncExecutor(){
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(10); //核心线程数
        executor.setMaxPoolSize(50); //最大线程数
        executor.setQueueCapacity(200); //等待队列的大小
        executor.setKeepAliveSeconds(60); //空闲线程的存活时间
        executor.setThreadNamePrefix("async-thread-"); //名称前缀

        // 线程池对拒绝任务的处理策略
        // CallerRunsPolicy:由调用线程(提交任务的线程)处理该任务
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        // 初始化
        executor.initialize();
        return executor;
    }

}

2、编写多线程的调用

在方法上使用注解,并指定使用的线程池@Async("asyncExecutor")

@Slf4j
@Service
@SuppressWarnings("all")
public class MyPositionBiz extends BaseBiz {
@Async("asyncExecutor")
    public void syncNoPush(Map params) {
        try {
            System.out.println(Thread.currentThread().getName());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

3、直接写unit测试或者在controller中调用即可。

不要忘记在spring boot启动类上开启注解 @EnableAsync

ItVuer - 免责声明 - 关于我们 - 联系我们

本网站信息来源于互联网,如有侵权请联系:561261067@qq.com

桂ICP备16001015号