Moved Scheduler and Schedulers to the .util.concurrent package.

CHANGES.md

@@ -1,9 +1,14 @@
 # 0.5.1
 
+### New Features
+
+* Added `RetryPolicy.abortOn`, `abortWhen` and `abortIf` methods to abort retries when matched.
+
 ### API Changes
 
 * `RetryPolicy.retryWhen` was renamed to `retryIf` for retrying if a `Predicate` is matched.
 * `RetryPolicy.retryFor` was renamed to `retryWhen` for retrying when a result is matched.
+* `Scheduler` and `Schedulers` were moved to `net.jodah.recurrent.util.concurrent`.
 
 # 0.5.0
 

pom.xml

@@ -112,6 +112,7 @@
         <configuration>
           <author>false</author>
           <show>public</show>
+          <excludePackageNames>*.internal</excludePackageNames>
           <additionalparam>
             -Xdoclint:none
             -notimestamp

src/main/java/net/jodah/recurrent/AsyncInvocation.java

@@ -4,6 +4,7 @@
 import java.util.concurrent.TimeUnit;
 
 import net.jodah.recurrent.internal.util.Assert;
+import net.jodah.recurrent.util.concurrent.Scheduler;
 
 /**
  * Tracks asynchronous invocations and allows retries to be scheduled according to a {@link RetryPolicy}.

src/main/java/net/jodah/recurrent/AsyncListeners.java

@@ -8,6 +8,7 @@
 import net.jodah.recurrent.event.ContextualResultListener;
 import net.jodah.recurrent.event.ResultListener;
 import net.jodah.recurrent.internal.util.Assert;
+import net.jodah.recurrent.util.concurrent.Scheduler;
 
 /**
  * Recurrent event listeners that are called asynchronously on the {@link Scheduler} or {@link ScheduledExecutorService}

src/main/java/net/jodah/recurrent/InvocationStats.java

@@ -1,7 +1,7 @@
 package net.jodah.recurrent;
 
 /**
- * Retry statistics.
+ * Invocation statistics.
  * 
  * @author Jonathan Halterman
  */

src/main/java/net/jodah/recurrent/Recurrent.java

@@ -6,6 +6,8 @@
 import java.util.concurrent.TimeUnit;
 
 import net.jodah.recurrent.internal.util.Assert;
+import net.jodah.recurrent.util.concurrent.Scheduler;
+import net.jodah.recurrent.util.concurrent.Schedulers;
 
 /**
  * Performs invocations with synchronous or asynchronous retries according to a {@link RetryPolicy}. Asynchronous

src/main/java/net/jodah/recurrent/RecurrentFuture.java

@@ -14,6 +14,7 @@
 import net.jodah.recurrent.event.SuccessListener;
 import net.jodah.recurrent.internal.util.Assert;
 import net.jodah.recurrent.internal.util.concurrent.ReentrantCircuit;
+import net.jodah.recurrent.util.concurrent.Scheduler;
 
 /**
  * A future result of an asynchronous operation.

src/main/java/net/jodah/recurrent/util/concurrent/DefaultScheduledFuture.java

@@ -13,36 +13,57 @@
  * @param <T> result type
  */
 public class DefaultScheduledFuture<T> implements ScheduledFuture<T> {
+  /**
+   * @return {@code 0}
+   */
   @Override
   public long getDelay(TimeUnit unit) {
     return 0;
   }
 
+  /**
+   * @return {@code 0}
+   */
   @Override
   public int compareTo(Delayed o) {
     return 0;
   }
 
+  /**
+   * @return {@code false}
+   */
   @Override
   public boolean cancel(boolean mayInterruptIfRunning) {
     return false;
   }
 
+  /**
+   * @return {@code false}
+   */
   @Override
   public boolean isCancelled() {
     return false;
   }
 
+  /**
+   * @return {@code false}
+   */
   @Override
   public boolean isDone() {
     return false;
   }
 
+  /**
+   * @return {@code null}
+   */
   @Override
   public T get() throws InterruptedException, ExecutionException {
     return null;
   }
 
+  /**
+   * @return {@code null}
+   */
   @Override
   public T get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException {
     return null;

src/main/java/net/jodah/recurrent/Scheduler.java → src/main/java/net/jodah/recurrent/util/concurrent/Scheduler.java

@@ -1,4 +1,4 @@
-package net.jodah.recurrent;
+package net.jodah.recurrent.util.concurrent;
 
 import java.util.concurrent.Callable;
 import java.util.concurrent.ScheduledFuture;

src/main/java/net/jodah/recurrent/Schedulers.java → src/main/java/net/jodah/recurrent/util/concurrent/Schedulers.java

@@ -1,4 +1,4 @@
-package net.jodah.recurrent;
+package net.jodah.recurrent.util.concurrent;
 
 import java.util.concurrent.Callable;
 import java.util.concurrent.ScheduledExecutorService;

src/test/java/net/jodah/recurrent/AsyncInvocationTest.java

@@ -14,6 +14,8 @@
 import org.testng.annotations.BeforeMethod;
 import org.testng.annotations.Test;
 
+import net.jodah.recurrent.util.concurrent.Scheduler;
+
 @Test
 public class AsyncInvocationTest {
   ConnectException e = new ConnectException();

src/test/java/net/jodah/recurrent/examples/VertxExample.java

@@ -8,8 +8,8 @@
 import io.vertx.core.eventbus.ReplyFailure;
 import net.jodah.recurrent.Recurrent;
 import net.jodah.recurrent.RetryPolicy;
-import net.jodah.recurrent.Scheduler;
 import net.jodah.recurrent.util.concurrent.DefaultScheduledFuture;
+import net.jodah.recurrent.util.concurrent.Scheduler;
 
 public class VertxExample {
   static Vertx vertx = Vertx.vertx();