|
|
|
@ -1,13 +1,14 @@ |
|
|
|
|
package com.ruoyi.framework.config; |
|
|
|
|
|
|
|
|
|
import java.util.concurrent.ScheduledExecutorService; |
|
|
|
|
import java.util.concurrent.ScheduledThreadPoolExecutor; |
|
|
|
|
import java.util.concurrent.ThreadPoolExecutor; |
|
|
|
|
import com.ruoyi.common.utils.Threads; |
|
|
|
|
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; |
|
|
|
|
|
|
|
|
|
import java.util.concurrent.ScheduledExecutorService; |
|
|
|
|
import java.util.concurrent.ScheduledThreadPoolExecutor; |
|
|
|
|
import java.util.concurrent.ThreadPoolExecutor; |
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
* 线程池配置 |
|
|
|
@ -49,7 +50,8 @@ public class ThreadPoolConfig |
|
|
|
|
protected ScheduledExecutorService scheduledExecutorService() |
|
|
|
|
{ |
|
|
|
|
return new ScheduledThreadPoolExecutor(corePoolSize, |
|
|
|
|
new BasicThreadFactory.Builder().namingPattern("schedule-pool-%d").daemon(true).build()) |
|
|
|
|
new BasicThreadFactory.Builder().namingPattern("schedule-pool-%d").daemon(true).build(), |
|
|
|
|
new ThreadPoolExecutor.CallerRunsPolicy()) |
|
|
|
|
{ |
|
|
|
|
@Override |
|
|
|
|
protected void afterExecute(Runnable r, Throwable t) |
|
|
|
|