From 6df89da568bb35b2b980f250f8892e74481e117b Mon Sep 17 00:00:00 2001 From: Yun <995116474@qq.com> Date: Tue, 28 May 2024 17:36:18 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E4=B8=80=E4=BA=9B=E6=97=A5?= =?UTF-8?q?=E5=BF=97=E6=8F=90=E7=A4=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- cluster.go | 2 +- once.go | 2 +- single.go | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/cluster.go b/cluster.go index b76bb01..1ccb6f0 100644 --- a/cluster.go +++ b/cluster.go @@ -437,7 +437,7 @@ func (c *Cluster) doTask(ctx context.Context, taskId string) { defer func() { 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())) } }() diff --git a/once.go b/once.go index 4876f3f..c0bbad6 100644 --- a/once.go +++ b/once.go @@ -166,7 +166,7 @@ func (w *Once) watch() { func (w *Once) doTask(key string) { defer func() { if err := recover(); err != nil { - fmt.Println("timer:定时器出错", err) + fmt.Println("timer:回调任务panic", err) log.Println("errStack", string(debug.Stack())) } }() diff --git a/single.go b/single.go index 3a4d38b..a415320 100644 --- a/single.go +++ b/single.go @@ -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 { defer func() { 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())) } }()