[improve] : Optimize queues to obtain data and prevent cpu idling

alerter/src/main/java/org/apache/hertzbeat/alert/calculate/CalculateAlarm.java

@@ -123,7 +123,7 @@ private void startCalculate() {
                         calculate(metricsData);
                     }
                 } catch (InterruptedException ignored) {
-
+                    Thread.currentThread().interrupt();
                 } catch (Exception e) {
                     log.error("calculate alarm error: {}.", e.getMessage(), e);
                 }

common/src/main/java/org/apache/hertzbeat/common/queue/impl/InMemoryCommonDataQueue.java

@@ -20,7 +20,6 @@
 import java.util.HashMap;
 import java.util.Map;
 import java.util.concurrent.LinkedBlockingQueue;
-import java.util.concurrent.TimeUnit;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.hertzbeat.common.entity.alerter.Alert;
 import org.apache.hertzbeat.common.entity.message.CollectRep;
@@ -67,22 +66,22 @@ public void sendAlertsData(Alert alert) {
 
     @Override
     public Alert pollAlertsData() throws InterruptedException {
-        return alertDataQueue.poll(2, TimeUnit.SECONDS);
+        return alertDataQueue.take();
     }
 
     @Override
     public CollectRep.MetricsData pollMetricsDataToAlerter() throws InterruptedException {
-        return metricsDataToAlertQueue.poll(2, TimeUnit.SECONDS);
+        return metricsDataToAlertQueue.take();
     }
 
     @Override
     public CollectRep.MetricsData pollMetricsDataToPersistentStorage() throws InterruptedException {
-        return metricsDataToPersistentStorageQueue.poll(2, TimeUnit.SECONDS);
+        return metricsDataToPersistentStorageQueue.take();
     }
 
     @Override
     public CollectRep.MetricsData pollMetricsDataToRealTimeStorage() throws InterruptedException {
-        return metricsDataToRealTimeStorageQueue.poll(2, TimeUnit.SECONDS);
+        return metricsDataToRealTimeStorageQueue.take();
     }
 
     @Override

manager/src/main/java/org/apache/hertzbeat/manager/component/alerter/DispatcherAlarm.java

@@ -135,6 +135,7 @@ public void run() {
                     }
                 } catch (IgnoreException ignored) {
                 } catch (InterruptedException e) {
+                    Thread.currentThread().interrupt();
                     log.error(e.getMessage());
                 } catch (Exception exception) {
                     log.error(exception.getMessage(), exception);

warehouse/src/main/java/org/apache/hertzbeat/warehouse/store/DataStorageDispatch.java

@@ -61,6 +61,8 @@ private void startRealTimeDataStorage() {
                         continue;
                     }
                     realTimeDataWriter.saveData(metricsData);
+                } catch (InterruptedException interruptedException) {
+                    Thread.currentThread().interrupt();
                 } catch (Exception e) {
                     log.error(e.getMessage(), e);
                 }
@@ -78,8 +80,9 @@ protected void startPersistentDataStorage() {
                     if (metricsData == null) {
                         continue;
                     }
-
                     historyDataWriter.ifPresent(dataWriter -> dataWriter.saveData(metricsData));
+                } catch (InterruptedException interruptedException) {
+                    Thread.currentThread().interrupt();
                 } catch (Exception e) {
                     log.error(e.getMessage(), e);
                 }