Class TimerTest

vertx-core/src/test/java/io/vertx/tests/timer/TimerTest.java:37–429

@author Tim Fox

 * @author <a href="http://tfox.org">Tim Fox</a>
 */
public class TimerTest extends VertxTestBase2 {

  @Test
  public void testTimer(Checkpoint checkpoint) {
    timer(checkpoint, 1);
  }

  @Test
  public void testPeriodic1(Checkpoint checkpoint) {
    periodic(checkpoint, new PeriodicArg(100, 100), (delay, handler) -> vertx.setPeriodic(delay.delay, handler));
  }

  @Test
  public void testPeriodic2(Checkpoint checkpoint) {
    periodic(checkpoint, new PeriodicArg(100, 100), (delay, handler) -> vertx.setPeriodic(delay.delay, delay.delay, handler));
  }

  @Test
  public void testPeriodicWithInitialDelay1(Checkpoint checkpoint) {
    periodic(checkpoint, new PeriodicArg(0, 100), (delay, handler) -> vertx.setPeriodic(delay.initialDelay, delay.delay, handler));
  }

  @Test
  public void testPeriodicWithInitialDelay2(Checkpoint checkpoint) {
    periodic(checkpoint, new PeriodicArg(100, 200), (delay, handler) -> vertx.setPeriodic(delay.initialDelay, delay.delay, handler));
  }

  /**
   * Test the timers fire with approximately the correct delay
   */
  @Test
  public void testTimings(Checkpoint checkpoint) {
    final long start = System.nanoTime();
    final long delay = 2000;
    vertx.setTimer(delay, timerID -> {
      long dur = System.nanoTime() - start;
      Assert.assertTrue(dur >= TimeUnit.MILLISECONDS.toNanos(delay));
      long maxDelay = delay * 2;
      Assert.assertTrue("Timer accuracy: " + dur + " vs " + TimeUnit.MILLISECONDS.toNanos(maxDelay), dur < TimeUnit.MILLISECONDS.toNanos(maxDelay)); // 100% margin of error (needed for CI)
      vertx.cancelTimer(timerID);
      checkpoint.succeed();
    });
  }

  @Test
  public void testInVerticle(Checkpoint checkpoint1) {
    class MyVerticle extends AbstractVerticle {
      @Override
      public void start() {
        Thread thr = Thread.currentThread();
        vertx.setTimer(1, id -> {
          Assert.assertSame(thr, Thread.currentThread());
          checkpoint1.succeed();
        });
      }
    }
    MyVerticle verticle = new MyVerticle();
    vertx.deployVerticle(verticle);