Replace packet processing queue with mt-queue
This commit is contained in:
+19
@@ -0,0 +1,19 @@
|
|||||||
|
From 0000000000000000000000000000000000000000 Mon Sep 17 00:00:00 2001
|
||||||
|
From: NanaChiyo0721 <nanachiyo0721@163.com>
|
||||||
|
Date: Mon, 13 Jul 2026 23:10:31 +0800
|
||||||
|
Subject: [PATCH] Replace packet processing queue with mt-queue
|
||||||
|
|
||||||
|
|
||||||
|
diff --git a/net/minecraft/network/PacketProcessor.java b/net/minecraft/network/PacketProcessor.java
|
||||||
|
index 10fa576838c726d026df078eef6c693d14c2cbda..20fa23988efbfb50c664fa48cc823adbe8e6ce58 100644
|
||||||
|
--- a/net/minecraft/network/PacketProcessor.java
|
||||||
|
+++ b/net/minecraft/network/PacketProcessor.java
|
||||||
|
@@ -11,7 +11,7 @@ import org.slf4j.Logger;
|
||||||
|
|
||||||
|
public class PacketProcessor implements AutoCloseable {
|
||||||
|
private static final Logger LOGGER = LogUtils.getLogger();
|
||||||
|
- private final Queue<PacketProcessor.ListenerAndPacket<?>> packetsToBeHandled = Queues.newConcurrentLinkedQueue();
|
||||||
|
+ private final Queue<PacketProcessor.ListenerAndPacket<?>> packetsToBeHandled = new ca.spottedleaf.concurrentutil.collection.MultiThreadedQueue<>(); // Camellia - Replace packet processing queue with mt-queue
|
||||||
|
private final Thread runningThread;
|
||||||
|
private boolean closed;
|
||||||
|
|
||||||
Reference in New Issue
Block a user