Skip to content

Commit e0229f1

Browse files
committed
Input more info
1 parent fe19e57 commit e0229f1

File tree

1 file changed

+7
-0
lines changed
  • tang-starter/wheel-delay-queue-spring-boot-starter/src/main/kotlin/com/tang/queue/wheel

1 file changed

+7
-0
lines changed

tang-starter/wheel-delay-queue-spring-boot-starter/src/main/kotlin/com/tang/queue/wheel/SlotTask.kt

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,8 @@
11
package com.tang.queue.wheel
22

3+
import com.tang.commons.utils.LogUtils
34
import com.tang.queue.task.AbstractTask
5+
import org.slf4j.Logger
46
import java.util.concurrent.ConcurrentMap
57
import java.util.concurrent.ThreadPoolExecutor
68

@@ -28,9 +30,14 @@ class SlotTask(
2830

2931
) : Runnable {
3032

33+
companion object {
34+
private val LOGGER: Logger = LogUtils.getLogger()
35+
}
36+
3137
override fun run() {
3238
tasks.forEach { (taskId, task) ->
3339
if (task.cycleNum <= 0) {
40+
LOGGER.info("Task [$taskId] is ready to execute.")
3441
taskPool.execute(task)
3542
tasks.remove(taskId)
3643
queue.remove(taskId)

0 commit comments

Comments
 (0)