Skip to content

Commit

Permalink
Fixes for #5684
Browse files Browse the repository at this point in the history
Simplified CyclicTimeoutTest#testBusy

Signed-off-by: Greg Wilkins <gregw@webtide.com>
  • Loading branch information
gregw committed Mar 22, 2021
1 parent c59de80 commit da8a19c
Showing 1 changed file with 4 additions and 21 deletions.
25 changes: 4 additions & 21 deletions jetty-io/src/test/java/org/eclipse/jetty/io/CyclicTimeoutTest.java
Original file line number Diff line number Diff line change
Expand Up @@ -13,14 +13,11 @@

package org.eclipse.jetty.io;

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;

import org.eclipse.jetty.util.thread.QueuedThreadPool;
import org.eclipse.jetty.util.thread.ScheduledExecutorScheduler;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;

import static org.junit.jupiter.api.Assertions.assertFalse;
Expand Down Expand Up @@ -135,27 +132,13 @@ public void testMultiple() throws Exception
}

@Test
@Disabled
public void testBusy() throws Exception
{
QueuedThreadPool pool = new QueuedThreadPool(200);
pool.start();

long testUntil = System.nanoTime() + TimeUnit.MILLISECONDS.toNanos(1500);

assertTrue(_timeout.schedule(100, TimeUnit.MILLISECONDS));
long testUntil = System.nanoTime() + TimeUnit.MILLISECONDS.toNanos(2000);
assertTrue(_timeout.schedule(500, TimeUnit.MILLISECONDS));
while (System.nanoTime() < testUntil)
{
CountDownLatch latch = new CountDownLatch(1);
pool.execute(() ->
{
_timeout.schedule(100, TimeUnit.MILLISECONDS);
latch.countDown();
});
latch.await();
}

_timeout.schedule(500, TimeUnit.MILLISECONDS);
_timeout.cancel();
assertFalse(_expired);
pool.stop();
}
}

0 comments on commit da8a19c

Please sign in to comment.