fix: remove shutdownNow() that caused RejectedExecutionException cascade

shutdownNow() was called at the end of each analysis path to prevent
auto-close from hanging on stuck ANTLR threads. But it immediately
rejected all subsequent batch submissions, causing every file to be
skipped with RejectedExecutionException.

Fix: rely on the 30-second per-file timeout + Future.cancel(true)
to handle stuck files. After all futures are collected (completed or
cancelled), the try-with-resources auto-close calls shutdown() +
awaitTermination() which returns quickly since all tasks are done.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: aksOps

src/main/java/io/github/randomcodespace/iq/analyzer/Analyzer.java

@@ -261,7 +261,6 @@ private AnalysisResult runWithCache(Path root, Integer parallelism, AnalysisCach
                 final int idx = i;
                 final DiscoveredFile file = files.get(idx);
                 final AnalysisCache cacheRef = cache;
-                try {
                 futures.add(executor.submit(() -> {
                     // Check cache first
                     if (cacheRef != null) {
@@ -293,9 +292,6 @@ private AnalysisResult runWithCache(Path root, Integer parallelism, AnalysisCach
                     }
                     return null;
                 }));
-                } catch (java.util.concurrent.RejectedExecutionException e) {
-                    log.warn("Executor rejected task for {}, skipping", file.path());
-                }
             }
 
             // Collect in order -- deterministic regardless of thread completion order
@@ -312,8 +308,6 @@ private AnalysisResult runWithCache(Path root, Integer parallelism, AnalysisCach
                     log.warn("Analysis interrupted for {}", files.get(i).path());
                 }
             }
-            // Force-cancel any stuck threads before auto-close waits for them
-            executorService.shutdownNow();
         }
 
         if (cache != null && cacheHitsCounter.get() > 0) {
@@ -561,7 +555,6 @@ private AnalysisResult runBatchedWithCache(Path root, Integer parallelism, int b
                     for (int i = 0; i < batch.size(); i++) {
                         final int idx = i;
                         final DiscoveredFile file = batch.get(idx);
-                        try {
                         futures.add(batchExecutorService.submit(() -> {
                             if (incremental) {
                                 try {
@@ -590,9 +583,6 @@ private AnalysisResult runBatchedWithCache(Path root, Integer parallelism, int b
                             }
                             return null;
                         }));
-                        } catch (java.util.concurrent.RejectedExecutionException e) {
-                            log.warn("Executor rejected task for {}, skipping", file.path());
-                        }
                     }
 
                     // Collect in order
@@ -663,8 +653,6 @@ private AnalysisResult runBatchedWithCache(Path root, Integer parallelism, int b
                 batch.clear();
             }
         }
-            // Force-cancel any stuck threads before auto-close waits for them
-            batchExecutorService.shutdownNow();
         }
 
         if (cacheHits > 0) {
@@ -938,7 +926,6 @@ private int[] processSmartBatch(
         for (int i = 0; i < batch.size(); i++) {
             final int idx = i;
             final DiscoveredFile file = batch.get(idx);
-            try {
             futures.add(executor.submit(() -> {
                 if (incremental) {
                     try {
@@ -967,9 +954,6 @@ private int[] processSmartBatch(
                 }
                 return null;
             }));
-            } catch (java.util.concurrent.RejectedExecutionException e) {
-                log.warn("Executor rejected task for {}, skipping", file.path());
-            }
         }
 
         for (int i = 0; i < futures.size(); i++) {
@@ -1016,8 +1000,6 @@ private int[] processSmartBatch(
                 nodes += result.nodes().size();
                 edges += result.edges().size();
             }
-            // Force-cancel any stuck threads before auto-close waits for them
-            executor.shutdownNow();
         }
 
         if (!incremental && (!batchNodes.isEmpty() || !batchEdges.isEmpty())) {