+ replaced Terminable with AutoCloseable

Author: q3769

README.md

@@ -67,7 +67,7 @@ etc...
 #### API
 
 ```java
-public interface SequentialExecutorServiceFactory extends Terminable {
+public interface SequentialExecutorServiceFactory extends AutoCloseable {
     /**
      * @param sequenceKey
      *         an {@link Object} instance whose hash code is used to summon the corresponding executor.
@@ -78,40 +78,6 @@ public interface SequentialExecutorServiceFactory extends Terminable {
 }
 ```
 
-where ```Terminable``` is defined as
-
-```java
-public interface Terminable {
-    /**
-     * Initiates an orderly shutdown of all managed thread resources. Previously submitted tasks are executed, but no
-     * new tasks will be accepted. Invocation has no additional effect if already shut down.
-     * <p>
-     * This method does not wait for the previously submitted tasks to complete execution. Use an external awaiting
-     * mechanism to do that, with the help of {@link #isTerminated()}.
-     */
-    void shutdown();
-
-    /**
-     * Non-blocking
-     *
-     * @return true if all tasks of all managed executors have completed following shut down. Note that isTerminated is
-     *         never true unless shutdown was called first.
-     */
-    boolean isTerminated();
-
-    /**
-     * Attempts to stop all actively executing tasks, halts the processing of waiting tasks, and returns a list of the
-     * tasks that were awaiting execution.
-     * <p>
-     * This method does not wait for the previously submitted tasks to complete execution. Use an external awaiting
-     * mechanism to do that, with the help of {@link #isTerminated()}.
-     *
-     * @return Tasks submitted but never started executing
-     */
-    List<Runnable> shutdownNow();
-}
-```
-
 This API style loosely takes the form of "thread affinity". Sequence keys are used to summon executors of JDK
 type [ExecutorService](https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html). The same
 sequence key always gets back the same sequential executor. All tasks of that sequence key can then be "affined" to and
@@ -189,7 +155,7 @@ public class MessageConsumer {
 #### API
 
 ```java
-public interface SequentialExecutor extends Terminable {
+public interface SequentialExecutor extends AutoCloseable {
     /**
      * @param command
      *         the Runnable task to run sequentially with others under the same sequence key

pom.xml

@@ -27,7 +27,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>io.github.q3769</groupId>
     <artifactId>conseq4j</artifactId>
-    <version>20230923.0.20230924</version>
+    <version>20230924.0.0</version>
     <packaging>jar</packaging>
     <name>conseq4j</name>
     <description>A Java concurrent API to sequence related tasks while concurring unrelated ones</description>

src/main/java/conseq4j/Terminable.java

@@ -29,7 +29,6 @@
 
 import javax.annotation.Nonnull;
 import javax.annotation.concurrent.ThreadSafe;
-import java.util.List;
 import java.util.Map;
 import java.util.concurrent.*;
 
@@ -40,7 +39,7 @@
  */
 @ThreadSafe
 @ToString
-public final class ConseqExecutor implements SequentialExecutor {
+public final class ConseqExecutor implements SequentialExecutor, AutoCloseable {
 
     private final Map<Object, CompletableFuture<?>> activeSequentialTasks = new ConcurrentHashMap<>();
     private final ExecutorService adminService = Executors.newSingleThreadExecutor();
@@ -150,23 +149,9 @@ public <T> CompletableFuture<T> submit(@NonNull Callable<T> task, @NonNull Objec
     }
 
     @Override
-    public void shutdown() {
-        new Thread(() -> {
-            workerExecutorService.close();
-            adminService.shutdown();
-        }).start();
-    }
-
-    @Override
-    public boolean isTerminated() {
-        return this.workerExecutorService.isTerminated() && this.adminService.isTerminated();
-    }
-
-    @Override
-    public @Nonnull List<Runnable> shutdownNow() {
-        List<Runnable> neverStartedTasks = workerExecutorService.shutdownNow();
-        adminService.shutdownNow();
-        return neverStartedTasks;
+    public void close() {
+        workerExecutorService.close();
+        adminService.close();
     }
 
     int estimateActiveExecutorCount() {

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

@@ -24,8 +24,6 @@
 
 package conseq4j.execute;
 
-import conseq4j.Terminable;
-
 import java.util.concurrent.Callable;
 import java.util.concurrent.Future;
 
@@ -44,7 +42,7 @@
  *
  * @author Qingtian Wang
  */
-public interface SequentialExecutor extends Terminable {
+public interface SequentialExecutor {
     /**
      * @param command
      *         the Runnable task to run sequentially with others under the same sequence key

src/main/java/conseq4j/execute/SequentialExecutor.java

@@ -29,14 +29,12 @@
 
 import javax.annotation.Nonnull;
 import javax.annotation.concurrent.ThreadSafe;
-import java.util.Collection;
 import java.util.List;
 import java.util.Objects;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ConcurrentMap;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
-import java.util.stream.Collectors;
 
 import static java.lang.Math.floorMod;
 
@@ -49,7 +47,7 @@
 
 @ThreadSafe
 @ToString
-public final class ConseqServiceFactory implements SequentialExecutorServiceFactory {
+public final class ConseqServiceFactory implements SequentialExecutorServiceFactory, AutoCloseable {
     private final int concurrency;
     private final ConcurrentMap<Object, ShutdownDisabledExecutorService> sequentialExecutors;
 
@@ -92,22 +90,8 @@ public ExecutorService getExecutorService(@NonNull Object sequenceKey) {
     }
 
     @Override
-    public void shutdown() {
-        this.sequentialExecutors.values().parallelStream().forEach(ShutdownDisabledExecutorService::shutdownDelegate);
-    }
-
-    @Override
-    public boolean isTerminated() {
-        return this.sequentialExecutors.values().stream().allMatch(ExecutorService::isTerminated);
-    }
-
-    @Override
-    public List<Runnable> shutdownNow() {
-        return sequentialExecutors.values()
-                .parallelStream()
-                .map(ShutdownDisabledExecutorService::shutdownDelegateNow)
-                .flatMap(Collection::stream)
-                .collect(Collectors.toList());
+    public void close() {
+        sequentialExecutors.values().forEach(ExecutorService::close);
     }
 
     private int bucketOf(Object sequenceKey) {

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

@@ -23,8 +23,6 @@
  */
 package conseq4j.summon;
 
-import conseq4j.Terminable;
-
 import java.util.concurrent.ExecutorService;
 
 /**
@@ -36,7 +34,7 @@
  *
  * @author Qingtian Wang
  */
-public interface SequentialExecutorServiceFactory extends Terminable {
+public interface SequentialExecutorServiceFactory {
     /**
      * @param sequenceKey
      *         an {@link Object} instance whose hash code is used to summon the corresponding executor.