aboutsummaryrefslogtreecommitdiffhomepage
path: root/patches/server/0914-Configurable-chat-thread-limit.patch
diff options
context:
space:
mode:
Diffstat (limited to 'patches/server/0914-Configurable-chat-thread-limit.patch')
-rw-r--r--patches/server/0914-Configurable-chat-thread-limit.patch55
1 files changed, 55 insertions, 0 deletions
diff --git a/patches/server/0914-Configurable-chat-thread-limit.patch b/patches/server/0914-Configurable-chat-thread-limit.patch
new file mode 100644
index 0000000000..a5344da3a6
--- /dev/null
+++ b/patches/server/0914-Configurable-chat-thread-limit.patch
@@ -0,0 +1,55 @@
+From 0000000000000000000000000000000000000000 Mon Sep 17 00:00:00 2001
+From: Shane Freeder <[email protected]>
+Date: Sun, 18 Sep 2022 06:33:17 +0100
+Subject: [PATCH] Configurable chat thread limit
+
+By default, spigot shifts chat over to an unbounded thread pool,
+on a normal server, this really offers no gains, the creation of a thread
+on submitting to the pool on these servers eats more time vs just running it in
+the netty pipeline, however, on servers using plugins which do work in here, there
+could be some overall benefits to moving this stuff outside of the pipeline.
+
+In general, this patch does two things:
+1) Exposes the core size for the pool, this allows for ensuring that a number of threads
+sit around in the pool, mitigating the need for creating new threads; This IS however
+caveated, the ThreadPoolExecutor will ONLY create core threads as they're needed, it
+just won't allow for us to dip back under the # of core threads, this can potentially
+be mitigated by calling prestartCoreThread, however, I'm not sure if there is much justification
+for this
+2) Exposes a max size for the pool, as stated, by default this is unbounded, for most
+servers limiting the size of the pool is going to have 0 effects given how fast chat
+is actually processed, this is honestly really just exposed for the misnomers or people
+who just wanna ensure that this won't grow over a specific size if chat gets stupidly active
+
+diff --git a/src/main/java/io/papermc/paper/configuration/GlobalConfiguration.java b/src/main/java/io/papermc/paper/configuration/GlobalConfiguration.java
+index 84785fed0d85d78c4caf8fabe35c0e89a59240d5..4a8286c78a9a5e305b19cc5d316bc73a78e49b4d 100644
+--- a/src/main/java/io/papermc/paper/configuration/GlobalConfiguration.java
++++ b/src/main/java/io/papermc/paper/configuration/GlobalConfiguration.java
+@@ -252,13 +252,26 @@ public class GlobalConfiguration extends ConfigurationPart {
+ public Misc misc;
+
+ public class Misc extends ConfigurationPart {
++
++ public ChatThreads chatThreads;
+ public class ChatThreads extends ConfigurationPart.Post {
+ private int chatExecutorCoreSize = -1;
+ private int chatExecutorMaxSize = -1;
+
+ @Override
+ public void postProcess() {
+- // TODO: FILL
++ //noinspection ConstantConditions
++ if (net.minecraft.server.MinecraftServer.getServer() == null) return; // In testing env, this will be null here
++ int _chatExecutorMaxSize = (chatExecutorMaxSize <= 0) ? Integer.MAX_VALUE : chatExecutorMaxSize; // This is somewhat dumb, but, this is the default, do we cap this?;
++ int _chatExecutorCoreSize = Math.max(chatExecutorCoreSize, 0);
++
++ if (_chatExecutorMaxSize < _chatExecutorCoreSize) {
++ _chatExecutorMaxSize = _chatExecutorCoreSize;
++ }
++
++ java.util.concurrent.ThreadPoolExecutor executor = (java.util.concurrent.ThreadPoolExecutor) net.minecraft.server.MinecraftServer.getServer().chatExecutor;
++ executor.setCorePoolSize(_chatExecutorCoreSize);
++ executor.setMaximumPoolSize(_chatExecutorMaxSize);
+ }
+ }
+ public int maxJoinsPerTick = 3;