test blinks on overloaded agent

This commit is contained in:
Alexey Kudravtsev
2016-06-07 21:28:23 +03:00
parent 61a3f45b87
commit 46e27e347c
@@ -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);