add rule: optimizePlayerConnect

Author: OptiJava

src/main/java/io/github/optijava/opt_carpet_addition/OptCarpetSettings.java

@@ -125,4 +125,10 @@ public class OptCarpetSettings {
             category = {RuleCategory.FEATURE, RuleCategory.CLIENT}
     )
     public static boolean unescapeChatMessage = false;
+
+    @Rule(
+            desc = "Handle player connect in a new thread to reduce the lag.",
+            category = {RuleCategory.OPTIMIZATION, RuleCategory.EXPERIMENTAL}
+    )
+    public static boolean optimizePlayerConnect = false;
 }

src/main/java/io/github/optijava/opt_carpet_addition/mixins/async/MinecraftServer_Mixin.java

@@ -0,0 +1,20 @@
+package io.github.optijava.opt_carpet_addition.mixins.async;
+
+import io.github.optijava.opt_carpet_addition.utils.threading.Threading;
+import net.minecraft.server.MinecraftServer;
+import org.spongepowered.asm.mixin.Mixin;
+import org.spongepowered.asm.mixin.injection.At;
+import org.spongepowered.asm.mixin.injection.Inject;
+import org.spongepowered.asm.mixin.injection.callback.CallbackInfo;
+
+@Mixin(MinecraftServer.class)
+public class MinecraftServer_Mixin {
+
+    @Inject(
+            method = "shutdown()V",
+            at = @At("HEAD")
+    )
+    public void injectShutdown(CallbackInfo ci) {
+        Threading.THREAD_POOL.shutdown();
+    }
+}

src/main/java/io/github/optijava/opt_carpet_addition/mixins/async/optimizePlayerConnect/ServerLoginNetworkHandler_Mixin.java

@@ -0,0 +1,38 @@
+package io.github.optijava.opt_carpet_addition.mixins.async.optimizePlayerConnect;
+
+import io.github.optijava.opt_carpet_addition.OptCarpetAddition;
+import io.github.optijava.opt_carpet_addition.OptCarpetSettings;
+import io.github.optijava.opt_carpet_addition.utils.threading.Threading;
+import net.minecraft.server.network.ServerLoginNetworkHandler;
+import net.minecraft.server.network.ServerPlayerEntity;
+import org.spongepowered.asm.mixin.Mixin;
+import org.spongepowered.asm.mixin.injection.At;
+import org.spongepowered.asm.mixin.injection.Inject;
+import org.spongepowered.asm.mixin.injection.callback.CallbackInfo;
+
+@Mixin(ServerLoginNetworkHandler.class)
+public abstract class ServerLoginNetworkHandler_Mixin {
+
+    /**
+     * 此优化灵感来源于模组 Very Many Player
+     * <p>
+     * Mixin ServerLoginNetworkHandler.addToServer(Lnet/minecraft/server/network/ServerPlayerEntity;)V
+     *
+     * @author OptiJava
+     * @reason rule: optimizePlayerConnect
+     */
+    @Inject(
+            method = "addToServer(Lnet/minecraft/server/network/ServerPlayerEntity;)V",
+            at = @At("HEAD"),
+            cancellable = true
+    )
+    public void injectAddToServer(ServerPlayerEntity player, CallbackInfo ci) {
+        if (OptCarpetSettings.optimizePlayerConnect) {
+            Threading.THREAD_POOL.submit(() -> {
+                OptCarpetAddition.LOGGER.info("PlayerConnectThread started.");
+                ((ServerLoginNetworkHandler) (Object) this).server.getPlayerManager().onPlayerConnect(((ServerLoginNetworkHandler) (Object) this).connection, player);
+            });
+            ci.cancel();
+        }
+    }
+}

src/main/java/io/github/optijava/opt_carpet_addition/utils/threading/Threading.java

@@ -0,0 +1,11 @@
+package io.github.optijava.opt_carpet_addition.utils.threading;
+
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.SynchronousQueue;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
+
+public class Threading {
+    public static final ExecutorService THREAD_POOL = new ThreadPoolExecutor(1, 3, 60L, TimeUnit.SECONDS, new SynchronousQueue<>());
+
+}

src/main/resources/opt-carpet-addition.accesswidener

@@ -2,4 +2,5 @@ accessWidener v1 named
 accessible class net/minecraft/entity/mob/EndermanEntity$PickUpBlockGoal
 accessible class net/minecraft/entity/mob/EndermanEntity$PlaceBlockGoal
 mutable field net/minecraft/network/packet/c2s/play/ChatMessageC2SPacket chatMessage Ljava/lang/String;
-accessible field net/minecraft/network/packet/c2s/play/ChatMessageC2SPacket chatMessage Ljava/lang/String;
+accessible field net/minecraft/network/packet/c2s/play/ChatMessageC2SPacket chatMessage Ljava/lang/String;
+accessible field net/minecraft/server/network/ServerLoginNetworkHandler server Lnet/minecraft/server/MinecraftServer;

src/main/resources/opt-carpet-addition.mixins.json

@@ -4,11 +4,12 @@
   "package": "io.github.optijava.opt_carpet_addition.mixins",
   "compatibilityLevel": "JAVA_16",
   "mixins": [
-    "disabledLayEggs.ChickenEntity_Mixin",
+    "async.optimizePlayerConnect.ServerLoginNetworkHandler_Mixin",
     "disabledEnderManPickupGoal.EnderManEntity_Mixin",
     "disabledEnderManPlaceBlockGoal.EndermanEntity_Mixin",
-    "disabledNetherPortalSpawn.NetherPortalBlock_Mixin",
     "disabledEntityTick.ServerWorld_Mixin",
+    "disabledLayEggs.ChickenEntity_Mixin",
+    "disabledNetherPortalSpawn.NetherPortalBlock_Mixin",
     "disabledUpdateSuppressionErrorStackTrace.ThreadExecutor_Mixin"
   ],
   "client": [