From ac5e96ccd08f3b04e3503039fcb65db22aedb71c Mon Sep 17 00:00:00 2001 From: Lynn Date: Thu, 9 Feb 2023 18:31:09 +0800 Subject: [PATCH] util: add a sleep for `for` --- util/gpool/spmc/spmcpool.go | 1 + 1 file changed, 1 insertion(+) diff --git a/util/gpool/spmc/spmcpool.go b/util/gpool/spmc/spmcpool.go index d1a3bbb80c4aa..8afdf9db0c253 100644 --- a/util/gpool/spmc/spmcpool.go +++ b/util/gpool/spmc/spmcpool.go @@ -249,6 +249,7 @@ func (p *Pool[T, U, C, CT, TF]) ReleaseAndWait() { if p.Running() == 0 && p.heartbeatDone.Load() && p.waitingTask.Load() == 0 { return } + time.Sleep(5 * time.Millisecond) } }