use virtual threads for query execution

slackhq · Sep 24, 2023 · 93ea3a2 · 93ea3a2
1 parent bf9aaff
commit 93ea3a2
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/kaldb/src/main/java/com/slack/kaldb/chunkManager/ChunkManagerBase.java b/kaldb/src/main/java/com/slack/kaldb/chunkManager/ChunkManagerBase.java
@@ -68,11 +68,7 @@ private static ListeningExecutorService queryThreadPool() {
     return MoreExecutors.listeningDecorator(
         Executors.newFixedThreadPool(
             Math.max(1, Runtime.getRuntime().availableProcessors() - 2),
-            new ThreadFactoryBuilder()
-                .setNameFormat("chunk-manager-query-%d")
-                .setUncaughtExceptionHandler(
-                    (t, e) -> LOG.error("Exception on thread {}: {}", t.getName(), e))
-                .build()));
+            Thread.ofVirtual().name("chunk-manager-query-", 0).factory()));
   }
 
   /*