public/liteFlow
1
0
Fork 0
mirror of https://gitee.com/dromara/liteFlow.git synced 2026-05-14 12:12:08 +08:00
Code Issues Packages Projects Releases Wiki Activity

bug #I3CT9A 监控打印的耗时不准确问题

Browse Source
This commit is contained in:
zendwang
2021-03-26 16:46:37 +08:00
parent be6d85c289
commit c6545469f6
2 changed files with 30 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
liteflow-core/src/main/java/com/yomahub/liteflow/monitor/MonitorBus.java
View File

@@ -88,10 +88,9 @@ public class MonitorBus {
public void printStatistics(){
try{
Map<String, BigDecimal> compAverageTimeSpent = new HashMap<String, BigDecimal>();
long totalTimeSpent = 0;
for(Entry<String, BoundedPriorityQueue<CompStatistics>> entry : statisticsMap.entrySet()){
long totalTimeSpent = 0;
for(CompStatistics statistics : entry.getValue()){
totalTimeSpent += statistics.getTimeSpent();
}

28
liteflow-core/src/test/java/com/yomahub/liteflow/monitor/BoundedPriorityQueueTest.java Normal file
View File

@@ -0,0 +1,28 @@
package com.yomahub.liteflow.monitor;
import java.util.Iterator;
import java.util.PriorityQueue;
import cn.hutool.core.collection.BoundedPriorityQueue;
import cn.hutool.core.util.RandomUtil;
import org.junit.Test;
import com.yomahub.liteflow.entity.monitor.CompStatistics;
public class BoundedPriorityQueueTest {
@Test
public void test() throws InterruptedException {
PriorityQueue<CompStatistics> queue = new BoundedPriorityQueue<>(6);
for (int i = 0; i < 20 ; i ++) {
long randomTime = RandomUtil.randomLong(20);
Thread.sleep(randomTime);
queue.add(new CompStatistics("comp" + i, randomTime));
}
Iterator<CompStatistics> iterator = queue.iterator();
while(iterator.hasNext()) {
CompStatistics compStatistics = iterator.next();
System.out.println(compStatistics.getComponentClazzName() + " " + compStatistics.getTimeSpent());
}
}
}