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

make tests corePoolSize-independent

Browse Source
This commit is contained in:
Alexey Kudravtsev
2016-02-26 13:15:10 +03:00
parent f050641940
commit d42f1ffe9c
2 changed files with 18 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/platform-tests/testSrc/com/intellij/util/concurrency/AppScheduledExecutorServiceTest.java
+11 -8
View File
@@ -44,7 +44,8 @@ public class AppScheduledExecutorServiceTest extends TestCase {
assertFalse(service.isShutdown());
assertFalse(service.isTerminated());
service.invokeAll(Collections.nCopies(getBackendTPE(service).getCorePoolSize() + 1, Executors.callable(EmptyRunnable.getInstance()))); // pre-start all threads
ThreadPoolExecutor tpe = getBackendTPE(service);
service.invokeAll(Collections.nCopies(tpe.getCorePoolSize() + 1, Executors.callable(EmptyRunnable.getInstance()))); // pre-start all threads
int delay = 1000;
@@ -54,14 +55,14 @@ public class AppScheduledExecutorServiceTest extends TestCase {
}, delay, TimeUnit.MILLISECONDS);
assertFalse(service.isShutdown());
assertFalse(service.isTerminated());
assertFalse(getBackendTPE(service).isTerminating());
assertFalse(tpe.isTerminating());
ScheduledFuture<?> f2 = service.schedule((Runnable)() -> {
log.add(new LogInfo(2));
TimeoutUtil.sleep(10);
}, delay, TimeUnit.MILLISECONDS);
assertFalse(service.isShutdown());
assertFalse(service.isTerminated());
assertFalse(getBackendTPE(service).isTerminating());
assertFalse(tpe.isTerminating());
ScheduledFuture<?> f3 = service.schedule((Runnable)() -> {
log.add(new LogInfo(3));
TimeoutUtil.sleep(10);
@@ -69,12 +70,12 @@ public class AppScheduledExecutorServiceTest extends TestCase {
assertFalse(service.isShutdown());
assertFalse(service.isTerminated());
assertFalse(getBackendTPE(service).isTerminating());
assertFalse(tpe.isTerminating());
Future<?> f4 = service.submit((Runnable)() -> log.add(new LogInfo(4)));
assertFalse(service.isShutdown());
assertFalse(service.isTerminated());
assertFalse(getBackendTPE(service).isTerminating());
assertFalse(tpe.isTerminating());
assertFalse(f1.isDone());
assertFalse(f2.isDone());
assertFalse(f3.isDone());
@@ -157,7 +158,9 @@ public class AppScheduledExecutorServiceTest extends TestCase {
// pre-start one thread
Future<?> future = service.submit(EmptyRunnable.getInstance());
future.get();
assertEquals(1, getBackendTPE(service).getPoolSize());
ThreadPoolExecutor tpe = getBackendTPE(service);
service.setBackendPoolCorePoolSize(1);
assertEquals(1, tpe.getPoolSize());
int delay = 500;
@@ -165,7 +168,7 @@ public class AppScheduledExecutorServiceTest extends TestCase {
ScheduledFuture<?> f2 = service.schedule((Runnable)() -> log.add(new LogInfo(2)), delay + 100, TimeUnit.MILLISECONDS);
ScheduledFuture<?> f3 = service.schedule((Runnable)() -> log.add(new LogInfo(3)), delay + 200, TimeUnit.MILLISECONDS);
assertEquals(1, getBackendTPE(service).getPoolSize());
assertEquals(1, tpe.getPoolSize());
assertFalse(f1.isDone());
assertFalse(f2.isDone());
@@ -175,7 +178,7 @@ public class AppScheduledExecutorServiceTest extends TestCase {
assertTrue(f1.isDone());
assertTrue(f2.isDone());
assertTrue(f3.isDone());
assertEquals(1, getBackendTPE(service).getPoolSize());
assertEquals(1, tpe.getPoolSize());
assertEquals(3, log.size());
Set<Thread> usedThreads = new HashSet<>(Arrays.asList(log.get(0).currentThread, log.get(1).currentThread, log.get(2).currentThread));
platform/util/src/com/intellij/util/concurrency/AppScheduledExecutorService.java
+7
View File
@@ -103,6 +103,9 @@ public class AppScheduledExecutorService extends SchedulingWrapper {
public int getBackendPoolExecutorSize() {
return ((ThreadPoolExecutor)backendExecutorService).getPoolSize();
}
void setBackendPoolCorePoolSize(int size) {
((BackendThreadPoolExecutor)backendExecutorService).doSetCorePoolSize(size);
}
private static class BackendThreadPoolExecutor extends ThreadPoolExecutor {
BackendThreadPoolExecutor() {
@@ -151,6 +154,10 @@ public class AppScheduledExecutorService extends SchedulingWrapper {
error();
}
private void doSetCorePoolSize(int corePoolSize) {
super.setCorePoolSize(corePoolSize);
}
@Override
public void allowCoreThreadTimeOut(boolean value) {
error();