third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

[modify] add instanceId to pool's name to make debug more easy

Browse Source
This commit is contained in:
tjq 2020-06-14 10:45:28 +08:00
parent 17b27cf083
commit 7125e833e5
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/task/CommonTaskTracker.java
View File

@ -47,7 +47,9 @@ public class CommonTaskTracker extends TaskTracker {
@Override @Override
protected void initTaskTracker(ServerScheduleJobReq req) { protected void initTaskTracker(ServerScheduleJobReq req) {
ThreadFactory factory = new ThreadFactoryBuilder().setNameFormat("oms-TaskTrackerTimingPool-%d").build(); // CommonTaskTrackerTimingPool 缩写
String poolName = String.format("ctttp-%d", req.getInstanceId()) + "-%d";
ThreadFactory factory = new ThreadFactoryBuilder().setNameFormat(poolName).build();
this.scheduledPool = Executors.newScheduledThreadPool(2, factory); this.scheduledPool = Executors.newScheduledThreadPool(2, factory);
// 持久化根任务 // 持久化根任务

3
powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/task/FrequentTaskTracker.java
View File

@ -82,7 +82,8 @@ public class FrequentTaskTracker extends TaskTracker {
subInstanceId2TimeHolder = Maps.newConcurrentMap(); subInstanceId2TimeHolder = Maps.newConcurrentMap();
// 1. 初始化定时调度线程池 // 1. 初始化定时调度线程池
ThreadFactory factory = new ThreadFactoryBuilder().setNameFormat("oms-TaskTrackerTimingPool-%d").build(); String poolName = String.format("ftttp-%d", req.getInstanceId()) + "-%d";
ThreadFactory factory = new ThreadFactoryBuilder().setNameFormat(poolName).build();
this.scheduledPool = Executors.newScheduledThreadPool(3, factory); this.scheduledPool = Executors.newScheduledThreadPool(3, factory);
// 2. 启动任务发射器 // 2. 启动任务发射器