diff --git a/common/utils/timer/min_heap.go b/common/utils/timer/min_heap.go index 81a48c7d..27edb0ac 100644 --- a/common/utils/timer/min_heap.go +++ b/common/utils/timer/min_heap.go @@ -151,14 +151,7 @@ func (m *minHeap) process() { // 正在运行的任务数加1 atomic.AddInt32(&m.runCount, 1) go func() { - defer func() { - if err := recover(); err != nil { // 恢复 panic,err 为 panic 错误值 - // 1. 打印错误信息 - - fmt.Println(context.TODO(), "panic 错误:", err) - - } - }() + callback() // 对正在运行的任务数减1 atomic.AddInt32(&m.runCount, -1)