<div dir="ltr"><div dir="ltr"><div>A "solution / fix" to this issue that modifies the internals of <i>java.util.concurrent.ThreadPerTaskExector</i> is to:</div><div><b><br></b></div><div><b><br></b></div><div><b>1) Add a new interface InterruptableTask</b></div><div><br></div><div><span style="font-family:monospace">public interface InterruptableTask {<br></span></div><div><span style="font-family:monospace"><br></span></div><div><span style="font-family:monospace">    /**</span></div><div><span style="font-family:monospace">     * Return true if this is a task that is deemed to be in an idle state that can be interrupted.<br></span></div><div><span style="font-family:monospace">     */<br></span></div><div><span style="font-family:monospace">  Â  boolean canInterrupt();<br>}</span></div><div><br></div><div><br></div><div><b>2) Modify  java.util.concurrent.ThreadPerTaskExector by:</b></div><div><br></div><div><b>2i)</b> Changing the threads field from storing just Thread to additionally storing the associated task (Runnable or Callable) <br></div><div><br></div><div><span style="font-family:monospace">// instead of ...<br></span></div><div><span style="font-family:monospace">private final Set<Thread> threads = ConcurrentHashMap.newKeySet();<br></span></div><div><span style="font-family:monospace"><br></span></div><div><span style="font-family:monospace">// use a Map with values being the tasks (Runnable or Callable)<br></span></div><div><span style="font-family:monospace">private final Map<Thread, Object> threadTasks = new ConcurrentHashMap<>();</span></div><div><br></div><div><br></div><div><br></div><div><b>2ii)</b> Add a new internal method tryStopInterruptableTask():</div><div><br></div><div><span style="font-family:monospace">private void tryStopInterruptableTask() {<br>  threadTasks.entrySet().stream()<br>  Â  Â  Â .filter(entry -> entry.getKey().isAlive()) // Thread isAlive<br>  Â  Â  Â .filter(entry -> entry.getKey().getState() == Thread.State.WAITING) // Thread WAITING state<br>  Â  Â  Â .forEach(entry -> {<br>  Â  Â  Â  Â if (entry.getValue() instanceof InterruptableTask task) {<br>  Â  Â  Â  Â  Â if (task.canInterrupt()) { // application deems this task to NOT be in-flight (e.g. not IO waiting on database response)<br>  Â  Â  Â  Â  Â  Â entry.getKey().interrupt();<br>  Â  Â  Â  Â  Â }<br>  Â  Â  Â  Â }<br>  Â  Â  Â });<br>}</span></div><div><br></div><div><b>2 iii)</b> Call this method as part of shutdown() (or perhaps the internal tryShutdownAndTerminate())</div><div><br></div><div><br></div><div><br></div><div>With these changes, then the Nima specific ConnectionHandler just needs to implement InterruptableTask and then the usual <br></div><div>shutdown of the ExecutorService operates nicely.</div><div><br></div><div><span style="font-family:monospace">executor.shutdown();<br>if (!executor.awaitTermination(gracefulShutdownMillis, TimeUnit.MILLISECONDS)) {<br>  Â  List<Runnable> running = executor.shutdownNow();<br>  Â  if (!running.isEmpty()) {<br>  Â  Â  Â  LOGGER.log(INFO, running.size() + " channel tasks did not terminate gracefully");<br>  Â  }<br>}</span></div><div><br></div><div><br></div><div><br></div><div>Cheers, Rob.<br></div></div><br></div>