+ pulled back to be Java 8 compatible

Author: q3769

src/main/java/conseq4j/execute/ConseqExecutor.java

@@ -24,15 +24,16 @@
 
 package conseq4j.execute;
 
-import conseq4j.Terminable;
-import lombok.NonNull;
-import lombok.ToString;
 import static org.awaitility.Awaitility.await;
-import javax.annotation.Nonnull;
-import javax.annotation.concurrent.ThreadSafe;
+
+import conseq4j.Terminable;
 import java.util.List;
 import java.util.Map;
 import java.util.concurrent.*;
+import javax.annotation.Nonnull;
+import javax.annotation.concurrent.ThreadSafe;
+import lombok.NonNull;
+import lombok.ToString;
 
 /**
  * Relies on the JDK {@link CompletableFuture} as the sequential executor of the tasks under the same sequence key.
@@ -171,10 +172,10 @@ int estimateActiveExecutorCount() {
     @Override
     public void terminate() {
         new Thread(() -> {
-            workerExecutorService.shutdown();
-            await().forever().until(activeSequentialTasks::isEmpty);
-            adminService.shutdown();
-        })
+                    workerExecutorService.shutdown();
+                    await().forever().until(activeSequentialTasks::isEmpty);
+                    adminService.shutdown();
+                })
                 .start();
     }
 

src/main/java/conseq4j/summon/ConseqServiceFactory.java

@@ -23,19 +23,20 @@
  */
 package conseq4j.summon;
 
-import conseq4j.Terminable;
 import static java.lang.Math.floorMod;
-import lombok.NonNull;
-import lombok.ToString;
-import lombok.experimental.Delegate;
 import static org.awaitility.Awaitility.await;
-import javax.annotation.Nonnull;
-import javax.annotation.concurrent.ThreadSafe;
+
+import conseq4j.Terminable;
 import java.util.Collection;
 import java.util.List;
 import java.util.Objects;
 import java.util.concurrent.*;
 import java.util.stream.Collectors;
+import javax.annotation.Nonnull;
+import javax.annotation.concurrent.ThreadSafe;
+import lombok.NonNull;
+import lombok.ToString;
+import lombok.experimental.Delegate;
 
 /**
  * A factory to produce sequential executors of type {@link ExecutorService} with an upper-bound global execution

src/test/java/conseq4j/SpyingTask.java

@@ -23,13 +23,14 @@
  */
 package conseq4j;
 
-import lombok.Getter;
-import lombok.ToString;
 import static org.awaitility.Awaitility.await;
+
 import java.time.Duration;
 import java.util.Random;
 import java.util.concurrent.Callable;
 import java.util.concurrent.Executors;
+import lombok.Getter;
+import lombok.ToString;
 
 /**
  * @author Qingtian Wang

src/test/java/conseq4j/TestUtils.java

@@ -25,17 +25,17 @@
 package conseq4j;
 
 import static java.util.stream.Collectors.toList;
-import org.awaitility.Awaitility;
 import static org.junit.jupiter.api.Assertions.assertTrue;
+
 import java.util.List;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.Future;
 import java.util.stream.IntStream;
+import org.awaitility.Awaitility;
 
 public class TestUtils {
 
-    private TestUtils() {
-    }
+    private TestUtils() {}
 
     public static int actualExecutionThreadCount(List<SpyingTask> tasks) {
         return (int) tasks.stream().map(SpyingTask::getRunThreadName).distinct().count();

src/test/java/conseq4j/execute/ConseqExecutorTest.java

@@ -24,20 +24,21 @@
 
 package conseq4j.execute;
 
-import com.google.common.collect.Range;
-import conseq4j.SpyingTask;
-import conseq4j.TestUtils;
 import static conseq4j.TestUtils.awaitAllComplete;
 import static conseq4j.TestUtils.createSpyingTasks;
 import static java.util.stream.Collectors.toList;
 import static org.awaitility.Awaitility.await;
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertTrue;
-import org.junit.jupiter.api.Test;
+
+import com.google.common.collect.Range;
+import conseq4j.SpyingTask;
+import conseq4j.TestUtils;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.UUID;
 import java.util.concurrent.Future;
+import org.junit.jupiter.api.Test;
 
 class ConseqExecutorTest {
     private static final int TASK_COUNT = 100;

src/test/java/conseq4j/summon/ConfigTest.java

@@ -25,11 +25,12 @@
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertSame;
-import org.junit.jupiter.api.Test;
+
 import java.util.Random;
 import java.util.UUID;
 import java.util.concurrent.Executor;
 import java.util.concurrent.ExecutorService;
+import org.junit.jupiter.api.Test;
 
 /**
  * @author q3769

src/test/java/conseq4j/summon/ConseqServiceFactoryTest.java

@@ -23,22 +23,23 @@
  */
 package conseq4j.summon;
 
-import com.google.common.collect.Range;
-import conseq4j.SpyingTask;
-import conseq4j.TestUtils;
 import static conseq4j.TestUtils.createSpyingTasks;
 import static conseq4j.TestUtils.getIfAllCompleteNormal;
 import static java.util.stream.Collectors.toList;
 import static org.junit.jupiter.api.Assertions.*;
-import org.junit.jupiter.api.Nested;
-import org.junit.jupiter.api.Test;
+
+import com.google.common.collect.Range;
+import conseq4j.SpyingTask;
+import conseq4j.TestUtils;
 import java.util.List;
 import java.util.UUID;
 import java.util.concurrent.Callable;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Future;
 import java.util.stream.Collectors;
+import org.junit.jupiter.api.Nested;
+import org.junit.jupiter.api.Test;
 
 /**
  * @author Qingtian Wang