slhaf/Partner
1
0
Fork 0
mirror of https://github.com/slhaf/Partner.git synced 2026-05-12 08:43:02 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor(ActionScheduler): add debug logs for wheel start/stop, wait window, and action loading

Browse Source
This commit is contained in:
slhafzjw
2026-02-09 20:41:01 +08:00
parent 7c46f1d1ff
commit 656d6b65e3
1 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
Partner-Main/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/scheduler/ActionScheduler.kt
View File

@@ -151,6 +151,7 @@ class ActionScheduler : AgentRunningSubModule<Set<ScheduledActionData>, Void>()
} }
suspend fun CoroutineScope.wheel(launchingTime: ZonedDateTime, primaryTickAdvanceTime: Long) { suspend fun CoroutineScope.wheel(launchingTime: ZonedDateTime, primaryTickAdvanceTime: Long) {
log.debug("Wheel launched at {}, current nanoTime: {}", launchingTime, primaryTickAdvanceTime)
// 计算当前距离时内下次任务的剩余时间, 秒级推进 // 计算当前距离时内下次任务的剩余时间, 秒级推进
val launchingHour = launchingTime.hour val launchingHour = launchingTime.hour
var tick = launchingTime.minute * 60 + launchingTime.second var tick = launchingTime.minute * 60 + launchingTime.second
@@ -165,7 +166,7 @@ class ActionScheduler : AgentRunningSubModule<Set<ScheduledActionData>, Void>()
tick = (tick + step).coerceAtMost(wheel.lastIndex) tick = (tick + step).coerceAtMost(wheel.lastIndex)
lastTickAdvanceTime = current lastTickAdvanceTime = current
var shouldBreak: Boolean? = null var shouldBreak = false
var toTrigger: Set<ScheduledActionData>? = null var toTrigger: Set<ScheduledActionData>? = null
checkThenExecute { checkThenExecute {
@@ -187,7 +188,8 @@ class ActionScheduler : AgentRunningSubModule<Set<ScheduledActionData>, Void>()
// 取当前 tick、推进过程中经过的 tick 对应任务，异步启动 // 取当前 tick、推进过程中经过的 tick 对应任务，异步启动
} }
toTrigger?.let { onTrigger(it) } toTrigger?.let { onTrigger(it) }
if (shouldBreak!!) { if (shouldBreak) {
log.debug("Wheel stopped")
break break
} }
@@ -197,13 +199,16 @@ class ActionScheduler : AgentRunningSubModule<Set<ScheduledActionData>, Void>()
} }
suspend fun wait(currentTime: ZonedDateTime) { suspend fun wait(currentTime: ZonedDateTime) {
val nextHour = currentTime.truncatedTo(ChronoUnit.HOURS).plusHours(1)
val seconds = Duration.between( val seconds = Duration.between(
currentTime, currentTime.truncatedTo(ChronoUnit.HOURS).plusHours(1) currentTime, nextHour
).toMillis() ).toMillis()
// withTimeoutOrNull 内部已处理 seconds 小于 0 的情况 // withTimeoutOrNull 内部已处理 seconds 小于 0 的情况
log.debug("Start waiting {} ms at {}, target time: {}", seconds, currentTime, nextHour)
withTimeoutOrNull(seconds) { withTimeoutOrNull(seconds) {
state.first { it == WheelState.ACTIVE } state.first { it == WheelState.ACTIVE }
} }
log.debug("Waiting ended at {}", ZonedDateTime.now())
} }
timeWheelScope.launch { timeWheelScope.launch {
@@ -265,6 +270,7 @@ class ActionScheduler : AgentRunningSubModule<Set<ScheduledActionData>, Void>()
val load: (ZonedDateTime, ScheduledActionData) -> Unit = { latestExecutionTime, actionData -> val load: (ZonedDateTime, ScheduledActionData) -> Unit = { latestExecutionTime, actionData ->
val secondsTime = latestExecutionTime.minute * 60 + latestExecutionTime.second val secondsTime = latestExecutionTime.minute * 60 + latestExecutionTime.second
wheel[secondsTime].add(actionData) wheel[secondsTime].add(actionData)
log.debug("Action loaded to hour: {}", actionData)
} }
val repair: () -> Unit = { val repair: () -> Unit = {
@@ -279,6 +285,7 @@ class ActionScheduler : AgentRunningSubModule<Set<ScheduledActionData>, Void>()
fun loadDayActions(currentTime: ZonedDateTime) { fun loadDayActions(currentTime: ZonedDateTime) {
val load: (ZonedDateTime, ScheduledActionData) -> Unit = { latestExecutingTime, actionData -> val load: (ZonedDateTime, ScheduledActionData) -> Unit = { latestExecutingTime, actionData ->
actionsGroupByHour[latestExecutingTime.hour].add(actionData) actionsGroupByHour[latestExecutingTime.hour].add(actionData)
log.debug("Action loaded to day: {}", actionData)
} }
val repair: () -> Unit = { val repair: () -> Unit = {