From cecaab762d3c293890de38268c4d3cb24a399201 Mon Sep 17 00:00:00 2001
From: TheMode <themode@outlook.fr>
Date: Wed, 17 Nov 2021 09:20:04 +0100
Subject: [PATCH] Use a MpscGrowableArrayQueue

Signed-off-by: TheMode <themode@outlook.fr>
---
 src/main/java/net/minestom/server/network/socket/Worker.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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<SocketChannel, PlayerSocketConnection> connectionMap = new ConcurrentHashMap<>();
     private final Server server;
     private final PacketProcessor packetProcessor;
-    private final MpscUnboundedArrayQueue<Runnable> queue = new MpscUnboundedArrayQueue<>(1024);
+    private final MpscGrowableArrayQueue<Runnable> queue = new MpscGrowableArrayQueue<>(1024, Integer.MAX_VALUE / 2);
     private final AtomicBoolean flush = new AtomicBoolean();
 
     public Worker(Server server, PacketProcessor packetProcessor) throws IOException {