From 7b109dd9f272848ffd83a19f51ea6d34c645cf3e Mon Sep 17 00:00:00 2001 From: He-Pin Date: Sun, 12 Jan 2025 18:02:09 +0800 Subject: [PATCH] . --- cask/src/cask/internal/ThreadBlockingHandler.scala | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/cask/src/cask/internal/ThreadBlockingHandler.scala b/cask/src/cask/internal/ThreadBlockingHandler.scala index bf4ff0b0e1..340aba8c65 100644 --- a/cask/src/cask/internal/ThreadBlockingHandler.scala +++ b/cask/src/cask/internal/ThreadBlockingHandler.scala @@ -11,6 +11,10 @@ final class ThreadBlockingHandler(executor: Executor, handler: HttpHandler) exte require(executor ne null, "Executor should not be null") def handleRequest(exchange: HttpServerExchange): Unit = { + if (exchange.isInIoThread) { + exchange.dispatch(this) + return + } exchange.startBlocking() exchange.dispatch(executor, handler) }