From 27bed845438e558e472c51f270c7353ebbe89c94 Mon Sep 17 00:00:00 2001 From: Andrey Antukh Date: Thu, 2 Oct 2025 09:29:47 +0200 Subject: [PATCH] :sparkles: Improve netty io executor shutdown --- backend/src/app/worker/executor.clj | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/backend/src/app/worker/executor.clj b/backend/src/app/worker/executor.clj index f34239e7e0..7d9526be10 100644 --- 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