基于@EnableAsync使用线程池实现多线程

客官°小女子只卖身不卖艺 2022-12-28 11:16 127阅读 0赞

**目录**

@EnableAsync

@Async的使用

线程池Bean定义和异常处理配置

--------------------

**相对于传统编码的方式[使用多线程][Link 1]，在SpringBoot中有基于注解的更简单的实现方式：**

### **@EnableAsync** ###

项目中使用@EnableAsync开启异步功能

### @Async的使用 ###

使用@Async 注解在需要多线程处理的service内的方法上。这样在controller层直接调用service方法时，就可以实现@Async注解的方法在新线程独立执行。

**一般会在@Async上注明使用的线程池。**

> @Async 注解的方法要么就不要有返回值（void）,**如果有返回值那只能是future类型**，其他值会导致注解无效，不能异步执行
> 
> @Async注解 的方法在被调用时是独立线程调用，所以**全局异常处理器没办法处理方法抛出的异常**，**需要自己设置异常处理（实现AsyncConfigurer 接口重写getAsyncUncaughtExceptionHandler方法指定异常处理类）**

### 线程池Bean定义和异常处理配置  ###

import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.scheduling.annotation.AsyncConfigurer;
    import org.springframework.scheduling.annotation.EnableAsync;
    import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
     
    import java.util.concurrent.Executor;
     
    @Configuration
    @EnableAsync
    public class AsyncConfig implements AsyncConfigurer {
     
        @Override
        @Bean(name = "taskExecutor")
        public Executor getAsyncExecutor() {
            //线程池设置
            ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
            taskExecutor.setCorePoolSize( 20);//核心线程
            taskExecutor.setMaxPoolSize(50);//最大线程
            //拒绝策略 任务提交线程自身执行，不会拒绝抛异常导致任务失败
            taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
            taskExecutor.initialize();
            return taskExecutor;
        }
        //配置线程池执行异常的处理类（当多线程任务本身无catch处理时才抛给这个类进行处理）
        //AsyncConfigurer 接口中的这个方法用于返回异常时的处理类，就是上面自己定义的类
        @Override
        public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
            return new MyAsyncExceptionHandler();
        }
    
        //定义一个实现AsyncUncaughtExceptionHandler 接口的类，自定义多线程任务执行异常的处理逻辑
        class MyAsyncExceptionHandler implements AsyncUncaughtExceptionHandler {
            @Override
            public void handleUncaughtException(Throwable throwable, Method method, Object... objects) {
                System.out.println("------我是Async无返回方法的异常处理方法---------");
    System.out.println("Exception  in async method："+ throwable.getMessage());
            }
        }
    
    
        
    
    
        
    }

setRejectedExecutionHandler（）设置拒绝策略，分为四种：

ThreadPoolExecutor.AbortPolicy 丢弃任务并抛出RejectedExecutionException异常(默认)。  
ThreadPoolExecutor.DiscardPolic 丢弃任务，但是不抛出异常。  
ThreadPoolExecutor.DiscardOldestPolicy 丢弃队列最前面的任务，然后重新尝试执行任务  
ThreadPoolExecutor.CallerRunsPolic 由调用线程处理该任务

**上面的配置是通过java config方式实现一个ThreadPoolTaskExecutor 线程池并配置属性，@EnableAsync注解开启了项目的异步。**

@Async("taskExecutor")//指定使用上面创建的线程池
        public void asyncTask (int i){
            logger.info( "asyncTask   === > 第 {} 次 ",i );
        }

在要多线程执行的方法上使用    @Async注解，这样在调用这个方法的时候就会自动实现多线程异步执行，调用代码如下：

@Test
    public void AsyncTest (){
    	for (int i = 0; i < 11; i++) {
        	asyncService.asyncTask1( i );
    			
    	}
    }

就这样便达到了多线程执行asyncTask 方法的效果，是不是很简单~~~~~~~

[Link 1]: https://blog.csdn.net/qq_29569183/article/details/103330975