From 9fdb5615d6f6eb9b6059dff9fecb3be1bebdce6e Mon Sep 17 00:00:00 2001 From: Brian Neumann-Fopiano Date: Sun, 6 Sep 2026 12:11:56 -0400 Subject: [PATCH] Bounded routing test cleanup - Shutdown assertions interrupt and drain workers before fallback router close --- .../engine/history/GenerationHistoryRuntimeRouterTest.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/core/src/test/java/art/arcane/iris/engine/history/GenerationHistoryRuntimeRouterTest.java b/core/src/test/java/art/arcane/iris/engine/history/GenerationHistoryRuntimeRouterTest.java index fe5db35cf..06c930109 100644 --- a/core/src/test/java/art/arcane/iris/engine/history/GenerationHistoryRuntimeRouterTest.java +++ b/core/src/test/java/art/arcane/iris/engine/history/GenerationHistoryRuntimeRouterTest.java @@ -400,8 +400,9 @@ public final class GenerationHistoryRuntimeRouterTest { ExecutorService executor = Executors.newFixedThreadPool(9); CountDownLatch routing = new CountDownLatch(8); CompletableFuture[] workers = new CompletableFuture[8]; - try (GenerationHistoryRuntimeRouter router = GenerationHistoryRuntimeRouter.attach( - engine, history, (ignored, x, z) -> signature(x, z), runtimes)) { + GenerationHistoryRuntimeRouter router = GenerationHistoryRuntimeRouter.attach( + engine, history, (ignored, x, z) -> signature(x, z), runtimes); + try { for (int i = 0; i < workers.length; i++) { workers[i] = CompletableFuture.runAsync(() -> routeUntilClosed(router, routing), executor); } @@ -413,6 +414,7 @@ public final class GenerationHistoryRuntimeRouterTest { } finally { executor.shutdownNow(); assertTrue(executor.awaitTermination(5, TimeUnit.SECONDS)); + router.close(); } }