mirror of
https://github.com/LamGC/Oracle-Sentry.git
synced 2025-04-30 06:37:42 +00:00
refactor: 为线程池设置 ThreadFactory.
设置 ThreadFactory 以更好的辨别线程.
This commit is contained in:
parent
12d32737f2
commit
765b13f149
@ -1,6 +1,7 @@
|
|||||||
package net.lamgc.oracle.sentry.script.groovy.trigger;
|
package net.lamgc.oracle.sentry.script.groovy.trigger;
|
||||||
|
|
||||||
import com.google.common.base.Throwables;
|
import com.google.common.base.Throwables;
|
||||||
|
import com.google.common.util.concurrent.ThreadFactoryBuilder;
|
||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
|
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
|
||||||
@ -19,6 +20,9 @@ public class TimerTrigger implements GroovyTrigger {
|
|||||||
private final static ThreadPoolTaskScheduler SCHEDULER = new ThreadPoolTaskScheduler();
|
private final static ThreadPoolTaskScheduler SCHEDULER = new ThreadPoolTaskScheduler();
|
||||||
static {
|
static {
|
||||||
SCHEDULER.setPoolSize(Runtime.getRuntime().availableProcessors());
|
SCHEDULER.setPoolSize(Runtime.getRuntime().availableProcessors());
|
||||||
|
SCHEDULER.setThreadFactory(new ThreadFactoryBuilder()
|
||||||
|
.setNameFormat("Groovy-TimerTrigger-%d")
|
||||||
|
.build());
|
||||||
SCHEDULER.setErrorHandler(t -> log.error("脚本执行时发生异常.", t));
|
SCHEDULER.setErrorHandler(t -> log.error("脚本执行时发生异常.", t));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user