diff --git a/src/main/java/net/minestom/server/network/socket/Worker.java b/src/main/java/net/minestom/server/network/socket/Worker.java index 3f62f6fe1..b68b46650 100644 --- a/src/main/java/net/minestom/server/network/socket/Worker.java +++ b/src/main/java/net/minestom/server/network/socket/Worker.java @@ -7,7 +7,7 @@ import net.minestom.server.network.PacketProcessor; import net.minestom.server.network.player.PlayerSocketConnection; import net.minestom.server.thread.MinestomThread; import net.minestom.server.utils.binary.BinaryBuffer; -import org.jctools.queues.MpscUnboundedArrayQueue; +import org.jctools.queues.MpscGrowableArrayQueue; import org.jetbrains.annotations.ApiStatus; import java.io.IOException; @@ -31,7 +31,7 @@ public final class Worker extends MinestomThread { private final Map connectionMap = new ConcurrentHashMap<>(); private final Server server; private final PacketProcessor packetProcessor; - private final MpscUnboundedArrayQueue queue = new MpscUnboundedArrayQueue<>(1024); + private final MpscGrowableArrayQueue queue = new MpscGrowableArrayQueue<>(1024, Integer.MAX_VALUE / 2); private final AtomicBoolean flush = new AtomicBoolean(); public Worker(Server server, PacketProcessor packetProcessor) throws IOException {