From 46e27e347c562e1b9f0e797876ecab2eda72f4df Mon Sep 17 00:00:00 2001 From: Alexey Kudravtsev Date: Tue, 7 Jun 2016 15:11:57 +0300 Subject: [PATCH] test blinks on overloaded agent --- .../concurrency/AppScheduledExecutorServiceTest.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/platform/platform-tests/testSrc/com/intellij/util/concurrency/AppScheduledExecutorServiceTest.java b/platform/platform-tests/testSrc/com/intellij/util/concurrency/AppScheduledExecutorServiceTest.java index cc9d1f1cdf21..6727eb3a591e 100644 --- a/platform/platform-tests/testSrc/com/intellij/util/concurrency/AppScheduledExecutorServiceTest.java +++ b/platform/platform-tests/testSrc/com/intellij/util/concurrency/AppScheduledExecutorServiceTest.java @@ -46,7 +46,7 @@ public class AppScheduledExecutorServiceTest extends TestCase { service.invokeAll(Collections.nCopies(service.getBackendPoolCorePoolSize() + 1, Executors.callable(EmptyRunnable.getInstance()))); // pre-start all threads int delay = 1000; - + long start = System.currentTimeMillis(); ScheduledFuture f1 = service.schedule(() -> { log.add(new LogInfo(1)); TimeoutUtil.sleep(10); @@ -75,9 +75,10 @@ public class AppScheduledExecutorServiceTest extends TestCase { assertFalse(f3.isDone()); TimeoutUtil.sleep(delay/2); - assertFalse(f1.isDone()); - assertFalse(f2.isDone()); - assertFalse(f3.isDone()); + long elapsed = System.currentTimeMillis() - start; // can be > delay/2 on overloaded agent + assertEquals(elapsed > delay, f1.isDone()); + assertEquals(elapsed > delay, f2.isDone()); + assertEquals(elapsed > delay, f3.isDone()); assertTrue(f4.isDone()); TimeoutUtil.sleep(delay/2+500);