clean: Remove useless TaskExecutorServices.close(Executor)

Author: vorburger

src/dev/enola/be/io/NonBlockingLineWriter.java

@@ -9,8 +9,6 @@
 
 public class NonBlockingLineWriter extends TaskWithoutInputOutput implements LineWriter {
 
-    // TODO close() method to flush remaining messages? How would TaskExecutor know when to call it?
-
     private final LineWriter delegate;
     private final BlockingQueue<Object> queue;
     private boolean overflow;

src/dev/enola/be/task/TaskExecutor.java

@@ -127,7 +127,7 @@ public void close() {
             task.cancel();
         }
 
-        TaskExecutorServices.close(executor);
-        TaskExecutorServices.close(timeoutScheduler);
+        executor.close();
+        timeoutScheduler.close();
     }
 }

src/dev/enola/be/task/TaskExecutorServices.java

@@ -1,8 +1,5 @@
 package dev.enola.be.task;
 
-import static java.util.concurrent.TimeUnit.SECONDS;
-
-import java.time.Duration;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ThreadFactory;
@@ -42,35 +39,5 @@ static ExecutorService newVirtualThreadPerTaskExecutor() {
         return Executors.newThreadPerTaskExecutor(factory);
     }
 
-    private static final long CLOSE_EXECUTOR_SHUTDOWN_AWAIT_SECONDS = 7;
-
-    static void close(ExecutorService executor) {
-        var start = System.currentTimeMillis();
-        logger.fine(() -> "Starting to shut down ExecutorService " + executor);
-
-        // TODO Then (only) use Java 19+ executor.close()
-
-        executor.shutdown();
-        try {
-            // Wait for existing tasks to terminate
-            if (!executor.awaitTermination(CLOSE_EXECUTOR_SHUTDOWN_AWAIT_SECONDS, SECONDS)) {
-
-                // Cancel currently executing tasks
-                executor.shutdownNow();
-            }
-
-        } catch (InterruptedException ie) {
-            // (Re-)Cancel if current thread also interrupted
-            executor.shutdownNow();
-
-            // Preserve interrupt status
-            Thread.currentThread().interrupt();
-        }
-
-        var end = System.currentTimeMillis();
-        var duration = Duration.ofMillis(end - start);
-        logger.info(() -> "Finished shutting down ExecutorService " + executor + " in " + duration);
-    }
-
     private TaskExecutorServices() {}
 }