MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-09-27 10:03:11 +07:00
Code Issues Packages Projects Releases Wiki Activity

EA-122320 - CME: LongStreamEx.reduce

Browse Source
This commit is contained in:
Egor Ushakov
2018-12-28 17:38:49 +03:00
parent 66d0b4e60e
commit 9ff7c2a2a9
1 changed files with 13 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
java/debugger/impl/src/com/intellij/debugger/ui/overhead/OverheadTimings.java
+13 -11
View File
@@ -5,7 +5,7 @@ import com.intellij.debugger.engine.DebugProcess;
import com.intellij.openapi.util.Key;
import com.intellij.openapi.util.Pair;
import com.intellij.util.EventDispatcher;
import one.util.streamex.StreamEx;
import com.intellij.util.ObjectUtils;
import org.jetbrains.annotations.NotNull;
import org.jetbrains.annotations.Nullable;
@@ -23,22 +23,24 @@ public class OverheadTimings {
@SuppressWarnings("MismatchedQueryAndUpdateOfCollection")
private final List<Pair<Long, Timings>> myLast10Elements = new LinkedList<Pair<Long, Timings>>() {
private long totalTime = 0;
@Override
public boolean add(Pair<Long, Timings> o) {
public synchronized boolean add(Pair<Long, Timings> o) {
if (size() > 10) {
removeFirst();
if (isExcessive()) {
myEventDispatcher.getMulticaster().excessiveOverheadDetected();
}
Pair<Long, Timings> first = removeFirst();
if (first != null) {
totalTime -= ObjectUtils.notNull(first.getSecond().myTime, 0L);
}
}
boolean res = super.add(o);
if (isExcessive()) {
myEventDispatcher.getMulticaster().excessiveOverheadDetected();
}
return res;
totalTime += ObjectUtils.notNull(o.getSecond().myTime, 0L);
return super.add(o);
}
private boolean isExcessive() {
int size = size();
if (size < 5) return false;
long totalTime = StreamEx.of(this).map(p -> p.getSecond().myTime).nonNull().mapToLong(l -> l).sum();
long timeframe = getLast().first - getFirst().first;
return totalTime > timeframe || timeframe < 5;
}