package cn.flightfeather.supervision.timingtask
|
|
import java.time.LocalDateTime
|
import java.util.concurrent.ExecutorService
|
import java.util.concurrent.Executors
|
|
/**
|
* 定时任务基类
|
*/
|
abstract class BaseTimingTask {
|
|
companion object {
|
var threadPoo: ExecutorService? = Executors.newCachedThreadPool()
|
}
|
|
// 记录上次任务执行的时间点，单位：毫秒
|
private var lastTime: LocalDateTime = LocalDateTime.MIN
|
|
// 任务执行周期，单位：分钟
|
abstract val period: Long
|
|
fun execute(localtime:LocalDateTime) {
|
val now = LocalDateTime.now()
|
if (now.minusSeconds(period * 60 - 5) >= lastTime) {
|
lastTime = now
|
doTask(localtime)
|
}
|
}
|
|
abstract fun doTask(localtime:LocalDateTime)
|
}
|
