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

show more diagnostics for failing tests

Browse Source
This commit is contained in:
Alexey Kudravtsev
2017-12-21 12:52:37 +03:00
parent 8cac4aeeb0
commit 789e1d1f6e
1 changed files with 25 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/platform-tests/testSrc/com/intellij/util/AlarmTest.java
+25 -21
View File
@@ -34,7 +34,7 @@ package com.intellij.util;
import java.util.stream.Collectors;
import java.util.stream.Stream;
public class AlarmTest extends PlatformTestCase {
public class AlarmTest extends PlatformTestCase {
public void testTwoAddsWithZeroDelayMustExecuteSequentially() throws Exception {
Alarm alarm = new Alarm(getTestRootDisposable());
assertRequestsExecuteSequentially(alarm);
@@ -85,37 +85,41 @@ public class AlarmTest extends PlatformTestCase {
public void testOneAlarmDoesNotStartTooManyThreads() {
Alarm alarm = new Alarm(getTestRootDisposable());
Map<Thread, StackTraceElement[]> before = Thread.getAllStackTraces();
AtomicInteger executed = new AtomicInteger();
int N = 100000;
for (int i = 0; i < N; i++) {
alarm.addRequest(executed::incrementAndGet, 10);
}
while (executed.get() != N) {
UIUtil.dispatchAllInvocationEvents();
}
checkNotTooManyThreadsCreatedIn(()->{
for (int i = 0; i < N; i++) {
alarm.addRequest(executed::incrementAndGet, 10);
}
while (executed.get() != N) {
UIUtil.dispatchAllInvocationEvents();
}
});
}
private static void checkNotTooManyThreadsCreatedIn(Runnable runnable) {
Map<Thread, StackTraceElement[]> before = Thread.getAllStackTraces();
runnable.run();
Map<Thread, StackTraceElement[]> after = Thread.getAllStackTraces();
Map<Thread, List<StackTraceElement>> diff = new HashMap<>();
after.forEach((key, value) -> diff.put(key, Arrays.asList(value)));
before.keySet().forEach(diff::remove);
diff.keySet().removeAll(before.keySet());
if (!(after.size() - before.size() < 10)) {
fail("before: "+before.size()+"; after: "+after.size()+"Diff:\n"+diff);
fail("before: "+before.size()+"; after: "+after.size()+"; Diff:\n"+diff);
}
}
public void testManyAlarmsDoNotStartTooManyThreads() {
Map<Thread, StackTraceElement[]> before = Thread.getAllStackTraces();
AtomicInteger executed = new AtomicInteger();
int N = 100000;
List<Alarm> alarms = Stream.generate(() -> new Alarm(getTestRootDisposable())).limit(N).collect(Collectors.toList());
alarms.forEach(alarm -> alarm.addRequest(executed::incrementAndGet, 10));
checkNotTooManyThreadsCreatedIn(()->{
AtomicInteger executed = new AtomicInteger();
int N = 100000;
List<Alarm> alarms = Stream.generate(() -> new Alarm(getTestRootDisposable())).limit(N).collect(Collectors.toList());
alarms.forEach(alarm -> alarm.addRequest(executed::incrementAndGet, 10));
while (executed.get() != N) {
UIUtil.dispatchAllInvocationEvents();
}
Map<Thread, StackTraceElement[]> after = Thread.getAllStackTraces();
LOG.debug("before: "+before.size()+"; after: "+after.size());
assertTrue(after.size() - before.size() < 10);
while (executed.get() != N) {
UIUtil.dispatchAllInvocationEvents();
}
});
}
public void testOrderIsPreservedAfterModalitySwitching() {