From 3504f450ab983767ea5defacc8c18ae801b39168 Mon Sep 17 00:00:00 2001 From: David Roden Date: Sun, 26 Jan 2025 15:40:25 +0100 Subject: [PATCH] =?utf8?q?=F0=9F=90=9B=20Actually=20handle=20connections?= =?utf8?q?=20in=20a=20new=20thread?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit --- server/src/main/java/de/qsheltier/msta/Server.java | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/server/src/main/java/de/qsheltier/msta/Server.java b/server/src/main/java/de/qsheltier/msta/Server.java index 9ae3c38..626d976 100644 --- a/server/src/main/java/de/qsheltier/msta/Server.java +++ b/server/src/main/java/de/qsheltier/msta/Server.java @@ -83,9 +83,16 @@ public class Server implements Closeable { startLatch.countDown(); while (!closed.get()) { try { - try (var socket = serverSocket.accept()) { - handleSocket(socket.getInputStream(), socket.getOutputStream()); + var socket = serverSocket.accept(); + var inputStream = socket.getInputStream(); + var outputStream = socket.getOutputStream(); + new Thread(() -> { + try (var ignored = socket) { + handleSocket(inputStream, outputStream); + } catch (IOException e) { + /* swallow. */ } + }, "MSTA Handler for " + socket.getRemoteSocketAddress()).start(); } catch (IOException e) { /* swallow exceptions. */ } -- 2.7.4