From d32fb40a3258b143cc13234ae0367ffbbd6387f2 Mon Sep 17 00:00:00 2001
From: wenyh1 <2365151147@qq.com>
Date: Wed, 7 Dec 2022 13:19:13 +0800
Subject: [PATCH] [inner-2042] adjust statistic_queue_monitor

---
 .../dble/services/manager/response/StatisticCf.java       | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/actiontech/dble/services/manager/response/StatisticCf.java b/src/main/java/com/actiontech/dble/services/manager/response/StatisticCf.java
index 8c5af9213..490b90e01 100644
--- a/src/main/java/com/actiontech/dble/services/manager/response/StatisticCf.java
+++ b/src/main/java/com/actiontech/dble/services/manager/response/StatisticCf.java
@@ -447,14 +447,14 @@ public class StatisticCf {
 
             @Override
             public void run() {
-                if (count > observe) {
-                    StatisticManager.getInstance().cancelMonitoring();
-                    return;
-                }
                 StatisticManager.getInstance().
                         getUsageData().add(new UsageDataBlock(DateUtil.parseStr(System.currentTimeMillis(), DateUtil.DEFAULT_DATE_PATTERN),
                         DF.format(1 - (StatisticManager.getInstance().getDisruptorRemaining() / queueSize))));
                 count += interval;
+                if (count > observe) {
+                    StatisticManager.getInstance().cancelMonitoring();
+                    return;
+                }
             }
         }
     }