From 7125e833e594262915a51fe14a2b29dcb0517f1d Mon Sep 17 00:00:00 2001 From: tjq Date: Sun, 14 Jun 2020 10:45:28 +0800 Subject: [PATCH] [modify] add instanceId to pool's name to make debug more easy --- .../powerjob/worker/core/tracker/task/CommonTaskTracker.java | 4 +++- .../worker/core/tracker/task/FrequentTaskTracker.java | 3 ++- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/task/CommonTaskTracker.java b/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/task/CommonTaskTracker.java index 530b421d..848bd9e4 100644 --- a/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/task/CommonTaskTracker.java +++ b/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/task/CommonTaskTracker.java @@ -47,7 +47,9 @@ public class CommonTaskTracker extends TaskTracker { @Override 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); // 持久化根任务 diff --git a/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/task/FrequentTaskTracker.java b/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/task/FrequentTaskTracker.java index 88e97861..2d60b3ce 100644 --- a/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/task/FrequentTaskTracker.java +++ b/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/task/FrequentTaskTracker.java @@ -82,7 +82,8 @@ public class FrequentTaskTracker extends TaskTracker { subInstanceId2TimeHolder = Maps.newConcurrentMap(); // 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); // 2. 启动任务发射器