github-repos/mirai
1
0
Fork 0
mirror of https://github.com/mamoe/mirai.git synced 2025-01-10 18:40:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix TimedTask if not changed

Browse Source
This commit is contained in:
Him188 2021-04-16 13:03:06 +08:00
parent 2636cad32d
commit c96eb3ccf1
1 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
backend/mirai-console/src/util/CoroutineScopeUtils.kt
View File

@ -68,6 +68,11 @@ internal class TimedTask(
// `delay` always checks for cancellation // `delay` always checks for cancellation
lastChangedTime.loop { last -> lastChangedTime.loop { last ->
val current = currentTimeMillis() val current = currentTimeMillis()
if (last == UNCHANGED) {
runIgnoreException<CancellationException> {
delay(3.seconds) // accuracy not necessary
} ?: return@launch
} else {
if (current - last > intervalMillis) { if (current - last > intervalMillis) {
if (!lastChangedTime.compareAndSet(last, UNCHANGED)) return@loop if (!lastChangedTime.compareAndSet(last, UNCHANGED)) return@loop
action() action()
@ -77,6 +82,7 @@ internal class TimedTask(
} ?: return@launch } ?: return@launch
} }
} }
}
} }
internal fun CoroutineScope.launchTimedTask( internal fun CoroutineScope.launchTimedTask(