+ housekeeping

Author: q3769

src/test/java/conseq4j/SpyingTask.java

@@ -42,47 +42,44 @@ public class SpyingTask implements Runnable {
   private final Integer scheduledSequenceIndex;
   private String runThreadName;
   private long runThreadId;
-  private long runTimeEndMillis;
-  private long runTimeStartMillis;
+  private long runTimeEndNanos;
+  private long runTimeStartNanos;
 
   public SpyingTask(Integer scheduledSequenceIndex) {
     this.scheduledSequenceIndex = scheduledSequenceIndex;
     reset();
   }
 
-  public Duration getActualRunDuration() {
+  private Duration getActualRunDuration() {
     if (!isDone()) {
       throw new IllegalStateException("actual run duration not available until run completes");
     }
-    return Duration.ofMillis(this.runTimeEndMillis - this.runTimeStartMillis);
+    return Duration.ofNanos(this.runTimeEndNanos - this.runTimeStartNanos);
   }
 
   public boolean isDone() {
-    return this.runTimeStartMillis != UNSET_TIME_STAMP && this.runTimeEndMillis != UNSET_TIME_STAMP;
+    return this.runTimeStartNanos != UNSET_TIME_STAMP && this.runTimeEndNanos != UNSET_TIME_STAMP;
   }
 
   @Override
   public void run() {
     reset();
-    this.runTimeStartMillis = System.nanoTime();
+    this.runTimeStartNanos = System.nanoTime();
     this.runThreadName = Thread.currentThread().getName();
     this.runThreadId = Thread.currentThread().threadId();
     await()
         .with()
         .pollInterval(POLL_INTERVAL)
-        .until(() -> (System.nanoTime() - this.runTimeStartMillis) >= RUN_DURATION_MILLIS);
-    this.runTimeEndMillis = System.nanoTime();
+        .until(() -> (System.nanoTime() - this.runTimeStartNanos) >= RUN_DURATION_MILLIS);
+    this.runTimeEndNanos = System.nanoTime();
     System.out.printf(
         "Task %s run by %s:%s completed in %s%n",
-        scheduledSequenceIndex,
-        runThreadName,
-        runThreadId,
-        Duration.ofNanos(runTimeEndMillis - runTimeStartMillis));
+        scheduledSequenceIndex, runThreadName, runThreadId, getActualRunDuration());
   }
 
   private void reset() {
-    this.runTimeStartMillis = UNSET_TIME_STAMP;
-    this.runTimeEndMillis = UNSET_TIME_STAMP;
+    this.runTimeStartNanos = UNSET_TIME_STAMP;
+    this.runTimeEndNanos = UNSET_TIME_STAMP;
     this.runThreadName = null;
     this.runThreadId = UNSET_THREAD_ID;
   }

src/test/java/conseq4j/TestUtils.java

@@ -56,7 +56,7 @@ public static void assertConsecutiveRuntimes(@NonNull List<SpyingTask> tasks) {
     for (int i = 0; i < tasks.size() - 1; i++) {
       SpyingTask current = tasks.get(i);
       SpyingTask next = tasks.get(i + 1);
-      assertTrue(current.getRunTimeEndMillis() <= next.getRunTimeStartMillis());
+      assertTrue(current.getRunTimeEndNanos() <= next.getRunTimeStartNanos());
     }
   }