spring异步任务Async

向右看齐 2022-05-24 01:39 260阅读 0赞

1.总的来说,就是要先配置一个执行器:Executor ,然后spring就会自动的把这些异步任务交给这个执行器去执行

配置执行器,方法1:xml配置

<task:executor id="executorLaweye" pool-size="3-15" queue-capacity="500" />
        <task:annotation-driven executor="executorLaweye" />

配置方式2:java配置

@Configuration
    @EnableAsync
    public class SpringAsyncConfig { ... }

启用异步线程池

package com.hgh.springboot.spring4.ch3_2.taskexecutor;
    
    import java.util.concurrent.Executor;
    
    import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
    import org.springframework.context.annotation.ComponentScan;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.scheduling.annotation.AsyncConfigurer;
    import org.springframework.scheduling.annotation.EnableAsync;
    import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
    
    @Configuration
    @ComponentScan("com.hgh.springboot.spring4.ch3_2.taskexecutor")
    @EnableAsync
    public class TaskExecutorConfig implements AsyncConfigurer{ 
    
        public Executor getAsyncExecutor() {
            // TODO Auto-generated method stub
            ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
            taskExecutor.setCorePoolSize(5);
            taskExecutor.setMaxPoolSize(10);
            taskExecutor.setQueueCapacity(25);
            taskExecutor.initialize();
            return taskExecutor;
        }
    
    
    
        public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
            // TODO Auto-generated method stub
            return null;
        }
    
    }

定义异步任务

package com.hgh.springboot.spring4.ch3_2.taskexecutor;
    
    import org.springframework.scheduling.annotation.Async;
    import org.springframework.stereotype.Service;
    
    @Service
    public class AsyncTaskService { 
    
        @Async
        public void executeAsyncTask(Integer i){
            System.out.println("执行异步任务:" + i);
        }
    
        @Async
        public void executeAsyncTaskPlus(Integer i){
            System.out.println("执行异步任务2:" + (i +1));
        }
    }

测试类

package com.hgh.springboot.spring4.ch3_2.taskexecutor;
    
    import org.springframework.context.annotation.AnnotationConfigApplicationContext;
    
    public class Main {
    
        public static void main(String[] args) {
            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);
            }
            context.close();
        }
    }