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

修复monitorBus中限制队列没有限制的问题

Browse Source
This commit is contained in:
bryan.zhang
2018-01-23 13:56:39 +08:00
parent ad39678166
commit a71958acdd
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/com/thebeastshop/liteflow/monitor/MonitorBus.java
View File

@@ -45,15 +45,15 @@ public class MonitorBus {
public void run() { public void run() {
MonitorBus.printStatistics(); MonitorBus.printStatistics();
} }
}, 1*60*1000L, 5*60*1000L); }, 5*60*1000L, 5*60*1000L);
} }
public static void addStatistics(CompStatistics statistics){ public static void addStatistics(CompStatistics statistics){
if(statisticsMap.containsKey(statistics.getComponentClazzName())){ if(statisticsMap.containsKey(statistics.getComponentClazzName())){
statisticsMap.get(statistics.getComponentClazzName()).add(statistics); statisticsMap.get(statistics.getComponentClazzName()).offer(statistics);
}else{ }else{
LimitQueue<CompStatistics> queue = new LimitQueue<CompStatistics>(QUEUE_LIMIT_SIZE); LimitQueue<CompStatistics> queue = new LimitQueue<CompStatistics>(QUEUE_LIMIT_SIZE);
queue.add(statistics); queue.offer(statistics);
statisticsMap.put(statistics.getComponentClazzName(), queue); statisticsMap.put(statistics.getComponentClazzName(), queue);
} }
} }