DBot/KStarbound
DBot/KStarbound
3
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

Improvements to scheduling inside blockable event loop

Browse Source
This commit is contained in:
DBotThePony 2024-04-22 16:39:38 +07:00
parent 01c7a29fe8
commit 17a3de38bc
Signed by: DBot
GPG Key ID: DCC23B5715498507
1 changed files with 14 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
src/main/kotlin/ru/dbotthepony/kstarbound/util/BlockableEventLoop.kt
View File

@ -107,9 +107,9 @@ open class BlockableEventLoop(name: String) : Thread(name), ScheduledExecutorSer
private fun eventLoopIteration(): Boolean {
var executedAnything = false
val next = eventQueue.poll()
var next = eventQueue.poll()
if (next != null) {
while (next != null) {
executedAnything = true
try {
@ -127,24 +127,25 @@ open class BlockableEventLoop(name: String) : Thread(name), ScheduledExecutorSer
LOGGER.error("Caught an exception while propagating CompletableFuture to completeExceptionally stage", err)
}
}
// keep executing queued tasks until we hit scheduled task deadline
if (scheduledQueue.isEmpty() || scheduledQueue.peek()!!.executeAt > System.nanoTime())
next = eventQueue.poll()
else
next = null
}
if (scheduledQueue.isNotEmpty()) {
val executed = ObjectArrayList<ScheduledTask<*>>(4)
var lastSize: Int
do {
lastSize = executed.size
while (scheduledQueue.isNotEmpty() && (isShutdown || scheduledQueue.peek()!!.executeAt <= System.nanoTime())) {
executedAnything = true
val poll = scheduledQueue.poll()!!
while (scheduledQueue.isNotEmpty() && (isShutdown || scheduledQueue.peek()!!.executeAt <= System.nanoTime())) {
executedAnything = true
val poll = scheduledQueue.poll()!!
if (poll.perform(isShutdown)) {
executed.add(poll)
}
if (poll.perform(isShutdown)) {
executed.add(poll)
}
} while (lastSize != executed.size)
}
scheduledQueue.addAll(executed)
}