mirror of
				https://gitee.com/hhyykk/ipms-sjy.git
				synced 2025-10-31 10:18:42 +08:00 
			
		
		
		
	调整 API 访问日志,从 system 归到 infra 更合适
This commit is contained in:
		| @@ -1,58 +0,0 @@ | ||||
| package com.ruoyi.framework.config; | ||||
|  | ||||
| import java.util.concurrent.ScheduledExecutorService; | ||||
| import java.util.concurrent.ScheduledThreadPoolExecutor; | ||||
| import java.util.concurrent.ThreadPoolExecutor; | ||||
|  | ||||
| import org.apache.commons.lang3.concurrent.BasicThreadFactory; | ||||
| import org.springframework.context.annotation.Bean; | ||||
| import org.springframework.context.annotation.Configuration; | ||||
| import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; | ||||
| import com.ruoyi.common.utils.Threads; | ||||
|  | ||||
| /** | ||||
|  * 线程池配置 | ||||
|  * | ||||
|  * @author ruoyi | ||||
|  **/ | ||||
| @Configuration | ||||
| public class ThreadPoolConfig { | ||||
|     // 核心线程池大小 | ||||
|     private int corePoolSize = 50; | ||||
|  | ||||
|     // 最大可创建的线程数 | ||||
|     private int maxPoolSize = 200; | ||||
|  | ||||
|     // 队列最大长度 | ||||
|     private int queueCapacity = 1000; | ||||
|  | ||||
|     // 线程池维护线程所允许的空闲时间 | ||||
|     private int keepAliveSeconds = 300; | ||||
|  | ||||
|     @Bean(name = "threadPoolTaskExecutor") | ||||
|     public ThreadPoolTaskExecutor threadPoolTaskExecutor() { | ||||
|         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); | ||||
|         executor.setMaxPoolSize(maxPoolSize); | ||||
|         executor.setCorePoolSize(corePoolSize); | ||||
|         executor.setQueueCapacity(queueCapacity); | ||||
|         executor.setKeepAliveSeconds(keepAliveSeconds); | ||||
|         // 线程池对拒绝任务(无线程可用)的处理策略 | ||||
|         executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); | ||||
|         return executor; | ||||
|     } | ||||
|  | ||||
|     /** | ||||
|      * 执行周期性或定时任务 | ||||
|      */ | ||||
|     @Bean(name = "scheduledExecutorService") | ||||
|     protected ScheduledExecutorService scheduledExecutorService() { | ||||
|         return new ScheduledThreadPoolExecutor(corePoolSize, | ||||
|                 new BasicThreadFactory.Builder().namingPattern("schedule-pool-%d").daemon(true).build()) { | ||||
|             @Override | ||||
|             protected void afterExecute(Runnable r, Throwable t) { | ||||
|                 super.afterExecute(r, t); | ||||
|                 Threads.printException(r, t); | ||||
|             } | ||||
|         }; | ||||
|     } | ||||
| } | ||||
		Reference in New Issue
	
	Block a user
	 YunaiV
					YunaiV