From a7ae06167106e660e4d2bfdc2f885effc5d778da Mon Sep 17 00:00:00 2001
From: "1437892690@qq.com" <1437892690@qq.com>
Date: Sat, 20 Dec 2025 11:36:52 +0800
Subject: [PATCH] =?UTF-8?q?[=E5=8A=9F=E8=83=BD]=20=E7=BA=BF=E7=A8=8B?=
 =?UTF-8?q?=E6=B1=A0=E7=9B=91=E6=8E=A7=E9=A1=B5=E6=94=AF=E6=8C=81=E5=8F=AA?=
 =?UTF-8?q?=E6=98=BE=E7=A4=BA=E5=BD=93=E5=89=8D=E7=A7=9F=E6=88=B7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

关联 #[1579794183979011]线程池监控页支持只显示当前租户 http://192.168.0.96:8090/demo/rdm.html#/story-detail/939050947543040/939050947543042/1579794183979011
---
 .../asynchronization/thread/NeatLogicThread.java         | 4 ++++
 .../asynchronization/threadpool/CachedThreadPool.java    | 1 +
 .../framework/dto/healthcheck/ThreadTaskVo.java          | 9 +++++++++
 3 files changed, 14 insertions(+)

diff --git a/src/main/java/neatlogic/framework/asynchronization/thread/NeatLogicThread.java b/src/main/java/neatlogic/framework/asynchronization/thread/NeatLogicThread.java
index c95aaf805..64ef4620e 100644
--- a/src/main/java/neatlogic/framework/asynchronization/thread/NeatLogicThread.java
+++ b/src/main/java/neatlogic/framework/asynchronization/thread/NeatLogicThread.java
@@ -44,6 +44,10 @@ public abstract class NeatLogicThread implements Runnable, Comparable<NeatLogicT
         return Integer.compare(this.priority, other.priority); // 优先级高的先出队,priority越小代表优先级越高
     }
 
+    public String getTenantUuid() {
+        return tenantUuid;
+    }
+
     public Semaphore getLock() {
         return lock;
     }
diff --git a/src/main/java/neatlogic/framework/asynchronization/threadpool/CachedThreadPool.java b/src/main/java/neatlogic/framework/asynchronization/threadpool/CachedThreadPool.java
index c6364abc3..7f49da041 100644
--- a/src/main/java/neatlogic/framework/asynchronization/threadpool/CachedThreadPool.java
+++ b/src/main/java/neatlogic/framework/asynchronization/threadpool/CachedThreadPool.java
@@ -65,6 +65,7 @@ public class CachedThreadPool {
                 threadVo.setPoolName("main");
                 threadVo.setStartTime(new Date());
                 threadVo.setPriority(nt.getPriority());
+                threadVo.setTenantUuid(nt.getTenantUuid());
                 threadTaskMap.put(nt.getId(), threadVo);
                 threadSet.add(nt.getThreadName());
             }
diff --git a/src/main/java/neatlogic/framework/dto/healthcheck/ThreadTaskVo.java b/src/main/java/neatlogic/framework/dto/healthcheck/ThreadTaskVo.java
index 26e52338b..17ac99c69 100644
--- a/src/main/java/neatlogic/framework/dto/healthcheck/ThreadTaskVo.java
+++ b/src/main/java/neatlogic/framework/dto/healthcheck/ThreadTaskVo.java
@@ -22,6 +22,7 @@ public class ThreadTaskVo {
     private String poolName;
     private String status;
     private int priority;
+    private String tenantUuid;
 
     public Long getId() {
         return id;
@@ -76,4 +77,12 @@ public class ThreadTaskVo {
     public void setPoolName(String poolName) {
         this.poolName = poolName;
     }
+
+    public String getTenantUuid() {
+        return tenantUuid;
+    }
+
+    public void setTenantUuid(String tenantUuid) {
+        this.tenantUuid = tenantUuid;
+    }
 }
-- 
Gitee