SpringBoot多线程

小灰灰 2021-09-29 02:10 288阅读 0赞

1.编写配置类  
@Configuration  
@ComponentScan(value="cn.ployer.demo")  
@EnableAsync//开启异步任务支持  
public class TaskExecutorConfig implements AsyncConfigurer\{

@Override  
    public Executor getAsyncExecutor() \{  
        // TODO Auto-generated method stub  
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();  
        executor.setCorePoolSize(5);  
        executor.setMaxPoolSize(10);  
        executor.setQueueCapacity(25);  
        executor.initialize();  
        return executor;  
    \}  
      
    @Override  
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() \{  
        // TODO Auto-generated method stub  
        return AsyncConfigurer.super.getAsyncUncaughtExceptionHandler();  
    \}  
\}

2.任务执行类

@Service  
public class AsyncTaskService \{

@Async//表明该方法是异步方法  
    public void executeAsyncTask(int i) \{  
        System.out.println("执行异步任务：" + i);  
    \}  
      
    @Async  
    public void executeAsyncTaskPlus(int i) \{  
        System.out.println("执行异步任务+1：" + (i+1));  
    \}  
\}

3.运行

public class Main \{

public static void main(String\[\] args) \{  
        // TODO Auto-generated method stub  
        AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(TaskExecutorConfig.class);  
        AsyncTaskService asyncTaskService = context.getBean(AsyncTaskService.class);  
          
        for (int i = 0; i < 10; i++) \{  
            asyncTaskService.executeAsyncTask(i);  
            asyncTaskService.executeAsyncTaskPlus(i);  
        \}  
    \}

4.结果

执行异步任务：2  
执行异步任务：1  
执行异步任务+1：3  
执行异步任务：3  
执行异步任务：0  
执行异步任务+1：1  
执行异步任务：5  
执行异步任务+1：6  
执行异步任务：6  
执行异步任务+1：7  
执行异步任务+1：2  
执行异步任务+1：8  
执行异步任务：7  
执行异步任务+1：5  
执行异步任务：9  
执行异步任务+1：10  
执行异步任务：4  
执行异步任务+1：4  
执行异步任务+1：9  
执行异步任务：8