1. BgTask增加onStatusChange参数，通过外界传递如何发送状态改变的消息 2. BackgroundTaskCtrl.kt 创建了B...

hcong

2024-12-03 6fdacca914ef38e6cc91292ef07c5af32bd92991

 src/main/kotlin/cn/flightfeather/supervision/common/executor/BgTask.kt

@@ -11,6 +11,7 @@
    val id: String,
    val name: String,
    private val task: () -> Boolean,
    private val onStatusChange: (status: BgTaskStatus) -> Unit
) {
    var taskStatus = BgTaskStatus(type, id, name)
    var future: Future<*>? = null
@@ -33,11 +34,13 @@
    fun success() {
        taskStatus.status = TaskStatus.SUCCESS
        complete()
        onStatusChange(taskStatus)
    }

    fun fail() {
        taskStatus.status = TaskStatus.FAIL
        complete()
        onStatusChange(taskStatus)
    }

    fun shutdown() {