moral.git - Gitblit

New file
			@@ -0,0 +1,42 @@
			package com.moral.api.config.Interceptor;


			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;

			//@Configuration
			@EnableAsync
			public class SyncConfiguration {

			@Bean(name = "asyncPoolTaskExecutor")
			public ThreadPoolTaskExecutor executor() {
			ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
			//核心线程数
			taskExecutor.setCorePoolSize(10);
			//线程池维护线程的最大数量,只有在缓冲队列满了之后才会申请超过核心线程数的线程
			taskExecutor.setMaxPoolSize(20);
			//缓存队列
			taskExecutor.setQueueCapacity(50);
			//许的空闲时间,当超过了核心线程出之外的线程在空闲时间到达之后会被销毁
			taskExecutor.setKeepAliveSeconds(200);
			//异步方法内部线程名称
			taskExecutor.setThreadNamePrefix("async-");
			/**
			* 当线程池的任务缓存队列已满并且线程池中的线程数目达到maximumPoolSize，如果还有任务到来就会采取任务拒绝策略
			* 通常有以下四种策略：
			* ThreadPoolExecutor.AbortPolicy:丢弃任务并抛出RejectedExecutionException异常。
			* ThreadPoolExecutor.DiscardPolicy：也是丢弃任务，但是不抛出异常。
			* ThreadPoolExecutor.DiscardOldestPolicy：丢弃队列最前面的任务，然后重新尝试执行任务（重复此过程）
			* ThreadPoolExecutor.CallerRunsPolicy：重试添加当前的任务，自动重复调用 execute() 方法，直到成功
			*/
			taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
			taskExecutor.initialize();
			return taskExecutor;
			}


			}