Force shutdown of thread pool

MCXboxBroadcast · Aug 6, 2024 · 11a05d4 · 11a05d4
1 parent 42afb88
commit 11a05d4
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/...r/src/main/java/com/rtm516/mcxboxbroadcast/bootstrap/geyser/MCXboxBroadcastExtension.java b/...r/src/main/java/com/rtm516/mcxboxbroadcast/bootstrap/geyser/MCXboxBroadcastExtension.java
@@ -15,6 +15,7 @@
 import org.geysermc.geyser.api.event.connection.GeyserBedrockPingEvent;
 import org.geysermc.geyser.api.event.lifecycle.GeyserDefineCommandsEvent;
 import org.geysermc.geyser.api.event.lifecycle.GeyserPostInitializeEvent;
+import org.geysermc.geyser.api.event.lifecycle.GeyserShutdownEvent;
 import org.geysermc.geyser.api.extension.Extension;
 import org.geysermc.geyser.api.util.MinecraftVersion;
 
@@ -177,6 +178,11 @@ public void onPostInitialize(GeyserPostInitializeEvent event) {
         });
     }
 
+    @Subscribe
+    public void onShutdown(GeyserShutdownEvent event) {
+        sessionManager.shutdown();
+    }
+
     @Subscribe
     public void onBedrockPing(GeyserBedrockPingEvent event) {
         if (sessionInfo == null) {

diff --git a/core/src/main/java/com/rtm516/mcxboxbroadcast/core/SessionManager.java b/core/src/main/java/com/rtm516/mcxboxbroadcast/core/SessionManager.java
@@ -167,7 +167,7 @@ public void shutdown() {
 
         // Shutdown self
         super.shutdown();
-        scheduledThreadPool.shutdown();
+        scheduledThreadPool.shutdownNow();
     }
 
     /**