pkg/timerx
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改一些日志提示

Browse Source
This commit is contained in:
Yun
2024-05-28 17:36:18 +08:00
parent 2cc97438b4
commit 6df89da568
3 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cluster.go
+1 -1
View File
@@ -437,7 +437,7 @@ func (c *Cluster) doTask(ctx context.Context, taskId string) {
defer func() { defer func() {
if err := recover(); err != nil { if err := recover(); err != nil {
c.logger.Errorf(ctx, "timer:定时器出错 err:%+v stack:%s", err, string(debug.Stack())) c.logger.Errorf(ctx, "timer:回调任务panic err:%+v stack:%s", err, string(debug.Stack()))
} }
}() }()
once.go
+1 -1
View File
@@ -166,7 +166,7 @@ func (w *Once) watch() {
func (w *Once) doTask(key string) { func (w *Once) doTask(key string) {
defer func() { defer func() {
if err := recover(); err != nil { if err := recover(); err != nil {
fmt.Println("timer:定时器出错", err) fmt.Println("timer:回调任务panic", err)
log.Println("errStack", string(debug.Stack())) log.Println("errStack", string(debug.Stack()))
} }
}() }()
single.go
+1 -1
View File
@@ -282,7 +282,7 @@ func (s *Single) iterator(ctx context.Context, nowTime time.Time) {
func (s *Single) doTask(ctx context.Context, call callback, extend interface{}) error { func (s *Single) doTask(ctx context.Context, call callback, extend interface{}) error {
defer func() { defer func() {
if err := recover(); err != nil { if err := recover(); err != nil {
s.logger.Errorf(ctx, "timer:定时器出错 err:%+v stack:%s", err, string(debug.Stack())) s.logger.Errorf(ctx, "timer:回调任务panic err:%+v stack:%s", err, string(debug.Stack()))
} }
}() }()