Update HotJoinC2SThread.java

Jab125 · Nov 23, 2024 · 08b3c10 · 08b3c10 · angrybirds0706 · Dec 30, 2024
1 parent b5bb85a
commit 08b3c10
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/src/main/java/dev/jab125/hotjoin/server/HotJoinC2SThread.java b/src/main/java/dev/jab125/hotjoin/server/HotJoinC2SThread.java
@@ -1,5 +1,6 @@
 package dev.jab125.hotjoin.server;
 
+import dev.jab125.hotjoin.HotJoin;
 import net.fabricmc.fabric.api.networking.v1.PacketByteBufs;
 import net.minecraft.network.FriendlyByteBuf;
 import net.minecraft.network.codec.StreamCodec;
@@ -34,8 +35,14 @@ private void run0() throws Throwable {
 		new Thread(() -> {
 			while (true) {
 				for (Consumer<HotJoinC2SThread> runnable : runnables) {
-					runnable.accept(this);
-					runnables.remove(runnable);
+					boolean success = false;
+					try {
+						runnable.accept(this);
+						success = true;
+					} catch (Throwable t) {
+						HotJoin.LOGGER.error("Failed to run action!", t);
+					}
+					if (success) runnables.remove(runnable);
 				}
 			}
 		}).start();