From fb04876b10f64da9a079f8f0811f1c3214998c1d Mon Sep 17 00:00:00 2001 From: "382673304@qq.com" <382673304@qq.com> Date: Mon, 12 Oct 2020 22:48:17 +0800 Subject: [PATCH] fix: change ticker to after --- registry/consul/registry.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/registry/consul/registry.go b/registry/consul/registry.go index a00ec2518..3a4bee286 100644 --- a/registry/consul/registry.go +++ b/registry/consul/registry.go @@ -194,7 +194,7 @@ func (r *consulRegistry) IsAvailable() bool { func (r *consulRegistry) Destroy() { if r.URL != nil { done := make(chan struct{}, 1) - ticker := time.NewTicker(r.timeOut) + ticker := time.After(r.timeOut) go func() { defer func() { if e := recover(); e != nil { @@ -209,9 +209,8 @@ func (r *consulRegistry) Destroy() { select { case <-done: logger.Infof("consulRegistry unregister done") - case <-ticker.C: + case <-ticker: logger.Errorf("consul unregister timeout") - ticker.Stop() } } close(r.done) -- GitLab