Browse Source

thread pool name optimize

xuxueli 6 years ago
parent
commit
e426ebc6b6

+ 8 - 1
xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobTriggerPoolHelper.java View File

6
 import org.slf4j.LoggerFactory;
6
 import org.slf4j.LoggerFactory;
7
 
7
 
8
 import java.util.concurrent.LinkedBlockingQueue;
8
 import java.util.concurrent.LinkedBlockingQueue;
9
+import java.util.concurrent.ThreadFactory;
9
 import java.util.concurrent.ThreadPoolExecutor;
10
 import java.util.concurrent.ThreadPoolExecutor;
10
 import java.util.concurrent.TimeUnit;
11
 import java.util.concurrent.TimeUnit;
11
 
12
 
25
             256,
26
             256,
26
             60L,
27
             60L,
27
             TimeUnit.SECONDS,
28
             TimeUnit.SECONDS,
28
-            new LinkedBlockingQueue<Runnable>(1000));
29
+            new LinkedBlockingQueue<Runnable>(1000),
30
+            new ThreadFactory() {
31
+                @Override
32
+                public Thread newThread(Runnable r) {
33
+                    return new Thread(r, "xxl-job, admin JobTriggerPoolHelper-triggerPool" + r.hashCode());
34
+                }
35
+            });
29
 
36
 
30
 
37
 
31
     public void addTrigger(final int jobId, final TriggerTypeEnum triggerType, final int failRetryCount, final String executorShardingParam, final String executorParam) {
38
     public void addTrigger(final int jobId, final TriggerTypeEnum triggerType, final int failRetryCount, final String executorShardingParam, final String executorParam) {