SpringBoot配置多线程

r囧r小猫 2022-05-12 02:30 146阅读 0赞

package com.example.demo13.config;
    
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
    import org.springframework.context.annotation.Bean;
    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.lang.reflect.Method;
    import java.util.concurrent.Executor;
    import java.util.concurrent.ThreadPoolExecutor;
    
    /**
     * 线程池配置
     *
     * @author dongchuan
     */
    @Configuration
    @EnableAsync
    @Slf4j
    public class AsyncTaskConfig implements AsyncConfigurer {
        /**
         * ThredPoolTaskExcutor的处理流程 当池子大小小于corePoolSize，就新建线程，并处理请求
         * 当池子大小等于corePoolSize，把请求放入workQueue中，池子里的空闲线程就去workQueue中取任务并处理
         * 当workQueue放不下任务时，就新建线程入池，并处理请求，如果池子大小撑到了maximumPoolSize，就用RejectedExecutionHandler来做拒绝处理
         * 当池子的线程数大于corePoolSize时，多余的线程会等待keepAliveTime长时间，如果无请求可处理就自行销毁
         */
        @Override
        @Bean(name = "threadPoolTaskExecutor")
        public Executor getAsyncExecutor() {
            ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
            // 最小线程数(核心线程数)
            taskExecutor.setCorePoolSize(300);
            // 最大线程数
            taskExecutor.setMaxPoolSize(400);
            // 等待队列(队列最大长度)
            taskExecutor.setQueueCapacity(1000);
            // 线程池维护线程所允许的空闲时间 ，单位s
            taskExecutor.setKeepAliveSeconds(300);
            // 线程池对拒绝任务(无线程可用)的处理策略
            taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
    
            taskExecutor.initialize();
            log.info("线程池初始化完成...");
            return taskExecutor;
        }
    
        /**
         * 异步异常处理
         *
         * @return
         */
        @Override
        public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
            return new SpringAsyncExceptionHandler();
        }
    
        class SpringAsyncExceptionHandler implements AsyncUncaughtExceptionHandler {
            @Override
            public void handleUncaughtException(Throwable throwable, Method method, Object... obj) {
                log.error("Exception occurs in async method", throwable.getMessage());
            }
        }
    }

package com.example.demo13.controller;
    
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
    import org.springframework.stereotype.Controller;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.ResponseBody;
    
    import java.util.ArrayList;
    import java.util.List;
    import java.util.Random;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.Future;
    
    @Controller
    @Slf4j
    @RequestMapping("/task")
    public class TestController {
     
        @Autowired
        private ThreadPoolTaskExecutor threadPoolTaskExecutor;
     
        @GetMapping("/asyn")
        @ResponseBody
        public long asyn() {
    
    		try {
    			List<Future<Integer>> list = new ArrayList<>();
    			for (int i = 0; i < 1000; i++) {
                    Future<Integer> future = threadPoolTaskExecutor.submit(() -> {
    					return new Random().nextInt(10);
                    });
                    list.add(future);
                }
    			long sum = 0;
    			for (Future<Integer> future : list){
                    try {
                        int integer = future.get();
                        sum+=integer;
                    } catch (InterruptedException | ExecutionException e) {
                        e.printStackTrace();
                    }
                }
    			return sum;
    		} catch (Exception e) {
    			//e.printStackTrace();
    			return 0;
    		}
    	}
    }