✨ Improve netty io executor shutdown

2025-12-11 22:14:05 +01:00 · 2025-10-02 09:29:47 +02:00
parent c6529f9585
commit 27bed84543
1 changed files with 6 additions and 2 deletions
--- a/backend/src/app/worker/executor.clj
+++ b/backend/src/app/worker/executor.clj
@@ -17,7 +17,8 @@
   io.netty.channel.nio.NioEventLoopGroup
   io.netty.util.concurrent.DefaultEventExecutorGroup
   java.util.concurrent.ExecutorService
-   java.util.concurrent.ThreadFactory))
+   java.util.concurrent.ThreadFactory
+   java.util.concurrent.TimeUnit))

 (set! *warn-on-reflection* true)

@@ -61,7 +62,10 @@

 (defmethod ig/halt-key! ::wrk/netty-io-executor
  [_ instance]
-  (px/shutdown! instance))
+  (deref (.shutdownGracefully ^NioEventLoopGroup instance
+                              (long 100)
+                              (long 1000)
+                              TimeUnit/MILLISECONDS)))

 ;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
 ;; IO Offload Executor