🚸 Allow stopping the server cleanly

diff --git a/server/src/main/java/de/qsheltier/msta/Server.java b/server/src/main/java/de/qsheltier/msta/Server.java
index c11c9ff..e5b02a5 100644 (file)
--- a/server/src/main/java/de/qsheltier/msta/Server.java
+++ b/server/src/main/java/de/qsheltier/msta/Server.java
@@ -77,7 +77,7 @@ public class Server implements Closeable {
                var startLatch = new CountDownLatch(1);
                new Thread(() -> {
                        startLatch.countDown();
-                       while (true) {
+                       while (!closed.get()) {
                                try {
                                        try (var socket = serverSocket.accept()) {
                                                handleSocket(socket.getInputStream(), socket.getOutputStream());
@@ -97,6 +97,7 @@ public class Server implements Closeable {
         */
        @Override
        public void close() throws IOException {
+               closed.set(true);
                serverSocket.close();
        }
 
@@ -171,5 +172,6 @@ public class Server implements Closeable {
 
        private final ServerSocket serverSocket = new ServerSocket();
        private final Runnable shutdownHook;
+       private final AtomicBoolean closed = new AtomicBoolean(false);
 
 }