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

platform: improve leak detection in tests

Browse Source 
GitOrigin-RevId: ecd24f2e198eac9131c204ba044f8fc29bba92b6
This commit is contained in:
Aleksey Pivovarov
2022-02-14 10:46:29 +00:00
committed by intellij-monorepo-bot
parent 224d48313e
commit a33b82d7c9
1 changed files with 43 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/platform-tests/testSrc/com/intellij/openapi/application/impl/NonBlockingReadActionTest.java
+43 -17
View File
@@ -203,33 +203,59 @@ public class NonBlockingReadActionTest extends LightPlatformTestCase {
}
public void testDoNotLeakFirstCancelledCoalescedAction() {
Object leak = new Object() {};
Object leak = new Object() {
};
Disposable disposable = Disposer.newDisposable();
Disposer.dispose(disposable);
CancellablePromise<String> p = ReadAction
.nonBlocking(() -> "a")
.expireWith(disposable)
.coalesceBy(leak)
.submit(AppExecutorUtil.getAppExecutorService());
assertTrue(p.isCancelled());
try {
CancellablePromise<String> p = ReadAction
.nonBlocking(() -> "a")
.expireWith(disposable)
.coalesceBy(leak)
.submit(AppExecutorUtil.getAppExecutorService());
assertTrue(p.isCancelled());
LeakHunter.checkLeak(NonBlockingReadActionImpl.getTasksByEquality(), leak.getClass());
LeakHunter.checkLeak(NonBlockingReadActionImpl.getTasksByEquality(), leak.getClass());
Disposer.disposeChildren(disposable, (child) -> {
throw new IllegalStateException(child.toString());
});
}
finally {
Disposer.dispose(disposable);
}
}
public void testDoNotLeakSecondCancelledCoalescedAction() throws Exception {
Executor executor = AppExecutorUtil.createBoundedApplicationPoolExecutor("TestDoNotLeakSecondCancelledCoalescedAction", 10);
Disposable disposable = Disposer.newDisposable();
try {
Executor executor = AppExecutorUtil.createBoundedApplicationPoolExecutor("TestDoNotLeakSecondCancelledCoalescedAction", 10);
Object leak = new Object(){};
CancellablePromise<String> p = ReadAction.nonBlocking(() -> "a").coalesceBy(leak).submit(executor);
WriteAction.run(() -> {
ReadAction.nonBlocking(() -> "b").coalesceBy(leak).submit(executor).cancel();
});
assertTrue(p.isDone());
Object leak = new Object() {
};
CancellablePromise<String> p = ReadAction.nonBlocking(() -> "a").coalesceBy(leak).submit(executor);
WriteAction.run(() -> {
ReadAction.nonBlocking(() -> "b")
.coalesceBy(leak)
.expireWith(disposable)
.submit(executor)
.cancel();
});
assertTrue(p.isDone());
((BoundedTaskExecutor) executor).waitAllTasksExecuted(1, TimeUnit.SECONDS);
((BoundedTaskExecutor)executor).waitAllTasksExecuted(1, TimeUnit.SECONDS);
LeakHunter.checkLeak(NonBlockingReadActionImpl.getTasksByEquality(), leak.getClass());
LeakHunter.checkLeak(NonBlockingReadActionImpl.getTasksByEquality(), leak.getClass());
Disposer.disposeChildren(disposable, (child) -> {
throw new IllegalStateException(child.toString());
});
}
finally {
Disposer.dispose(disposable);
}
}
public void testSyncExecutionHonorsConstraints() {
setupUncommittedDocument();