DBot/overdrive_that_matters
DBot/overdrive_that_matters
3
1
Fork 0
Code Issues 63 Pull Requests Packages Releases Wiki Activity

Micro optimizations regarding mattery network channel

Browse Source
This commit is contained in:
DBotThePony 2023-08-21 17:09:20 +07:00
parent dd2dab37a7
commit 6fbdb04ee4
Signed by: DBot
GPG Key ID: DCC23B5715498507
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/kotlin/ru/dbotthepony/mc/otm/network/MatteryNetworkChannel.kt
View File

@ -23,6 +23,7 @@ import java.math.BigInteger
import java.util.Optional import java.util.Optional
import java.util.concurrent.CompletableFuture import java.util.concurrent.CompletableFuture
import java.util.concurrent.ConcurrentLinkedDeque import java.util.concurrent.ConcurrentLinkedDeque
import java.util.concurrent.ConcurrentLinkedQueue
import java.util.concurrent.locks.LockSupport import java.util.concurrent.locks.LockSupport
import java.util.function.BiConsumer import java.util.function.BiConsumer
import java.util.function.Supplier import java.util.function.Supplier
@ -127,7 +128,7 @@ abstract class MatteryNetworkChannel(val version: String, val name: String) {
private val logger = LogManager.getLogger() private val logger = LogManager.getLogger()
private var thread: Thread? = null private var thread: Thread? = null
private val queue = ConcurrentLinkedDeque<Task>() private val queue = ConcurrentLinkedQueue<Task>()
@Volatile @Volatile
private var interrupt = false private var interrupt = false
@ -143,7 +144,7 @@ abstract class MatteryNetworkChannel(val version: String, val name: String) {
*/ */
private fun run() { private fun run() {
while (!interrupt) { while (!interrupt) {
val task = queue.pollFirst() val task = queue.poll()
if (task == null) { if (task == null) {
LockSupport.park() LockSupport.park()
@ -160,7 +161,9 @@ abstract class MatteryNetworkChannel(val version: String, val name: String) {
} }
internal fun onServerPostTick() { internal fun onServerPostTick() {
LockSupport.unpark(thread) if (queue.isNotEmpty()) {
LockSupport.unpark(thread)
}
} }
internal fun onServerStarting() { internal fun onServerStarting() {