From c0132cc8928f114e65af1ec06ece1186303504b2 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=A4=A9=E7=A9=BA=E5=B0=8F=E5=B0=8F?= <751634819@qq.com>
Date: Wed, 8 May 2024 02:43:27 +0000
Subject: [PATCH] =?UTF-8?q?update=20core/src/main/java/org/dromara/dynamic?=
 =?UTF-8?q?tp/core/monitor/collector/jmx/JMXCollector.java.=20=E6=AD=A4?=
 =?UTF-8?q?=E5=A4=84=E6=97=A0=E9=9C=80=E4=BD=BF=E7=94=A8cache=EF=BC=8C?=
 =?UTF-8?q?=E4=BD=BF=E7=94=A8=E4=BA=86=E5=8F=8D=E8=80=8C=E5=A2=9E=E5=8A=A0?=
 =?UTF-8?q?=E4=BA=86=E5=86=85=E5=AD=98=E5=BC=80=E9=94=80?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Signed-off-by: 天空小小 <751634819@qq.com>
---
 .../monitor/collector/jmx/JMXCollector.java   | 25 ++++++-------------
 1 file changed, 7 insertions(+), 18 deletions(-)

diff --git a/core/src/main/java/org/dromara/dynamictp/core/monitor/collector/jmx/JMXCollector.java b/core/src/main/java/org/dromara/dynamictp/core/monitor/collector/jmx/JMXCollector.java
index a7643b2b..1a957813 100644
--- a/core/src/main/java/org/dromara/dynamictp/core/monitor/collector/jmx/JMXCollector.java
+++ b/core/src/main/java/org/dromara/dynamictp/core/monitor/collector/jmx/JMXCollector.java
@@ -40,26 +40,15 @@ public class JMXCollector extends AbstractCollector {
 
     public static final String DTP_METRIC_NAME_PREFIX = "dtp.thread.pool";
 
-    /**
-     * thread pool stats map
-     */
-    private static final Map<String, ThreadPoolStats> GAUGE_CACHE = new ConcurrentHashMap<>();
-
     @Override
     public void collect(ThreadPoolStats threadPoolStats) {
-        if (GAUGE_CACHE.containsKey(threadPoolStats.getPoolName())) {
-            ThreadPoolStats poolStats = GAUGE_CACHE.get(threadPoolStats.getPoolName());
-            BeanUtils.copyProperties(threadPoolStats, poolStats);
-        } else {
-            try {
-                MBeanServer server = ManagementFactory.getPlatformMBeanServer();
-                ObjectName name = new ObjectName(DTP_METRIC_NAME_PREFIX + ":name=" + threadPoolStats.getPoolName());
-                ThreadPoolStatsJMX stats = new ThreadPoolStatsJMX(threadPoolStats);
-                server.registerMBean(stats, name);
-            } catch (JMException e) {
-                log.error("collect thread pool stats error", e);
-            }
-            GAUGE_CACHE.put(threadPoolStats.getPoolName(), threadPoolStats);
+        try {
+            MBeanServer server = ManagementFactory.getPlatformMBeanServer();
+            ObjectName name = new ObjectName(DTP_METRIC_NAME_PREFIX + ":name=" + threadPoolStats.getPoolName());
+            ThreadPoolStatsJMX stats = new ThreadPoolStatsJMX(threadPoolStats);
+            server.registerMBean(stats, name);
+        } catch (JMException e) {
+            log.error("collect thread pool stats error", e);
         }
     }
 
-- 
Gitee