AstralTransRocketries/minosoft
1
0
Fork 0
mirror of https://gitlab.bixilon.de/bixilon/minosoft.git synced 2025-09-17 11:24:56 -04:00
Code Issues Packages Projects Releases Wiki Activity

lower network priority generally

Browse Source
This commit is contained in:
Bixilon 2023-05-31 22:07:10 +02:00
parent 1dc689baf5
commit d95e508219
No known key found for this signature in database
GPG Key ID: 5CAD791931B09AC4
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/de/bixilon/minosoft/protocol/network/network/client/netty/pipeline/ClientPacketHandler.kt
View File

@ -40,7 +40,7 @@ class ClientPacketHandler(
override fun channelRead0(context: ChannelHandlerContext, queued: QueuedS2CP<*>) { override fun channelRead0(context: ChannelHandlerContext, queued: QueuedS2CP<*>) {
if (queued.type.threadSafe && (DefaultThreadPool.queueSize < DefaultThreadPool.threadCount - 1 || queued.type.lowPriority)) { // only handle async when thread pool not busy if (queued.type.threadSafe && (DefaultThreadPool.queueSize < DefaultThreadPool.threadCount - 1 || queued.type.lowPriority)) { // only handle async when thread pool not busy
val runnable = SimplePoolRunnable(priority = if (queued.type.lowPriority) ThreadPool.Priorities.HIGH else ThreadPool.Priorities.HIGHER) val runnable = SimplePoolRunnable(priority = if (queued.type.lowPriority) ThreadPool.Priorities.NORMAL else ThreadPool.Priorities.HIGH)
runnable.runnable = Runnable { tryHandle(context, queued.type, queued.packet) } runnable.runnable = Runnable { tryHandle(context, queued.type, queued.packet) }
DefaultThreadPool += runnable DefaultThreadPool += runnable
} else { } else {