simple code

Signed-off-by: Weizhen Wang <wangweizhen@pingcap.com>
pingcap · Jan 3, 2023 · b29e662 · b29e662
1 parent f62832a
commit b29e662
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/util/gpool/spmc/spmcpool.go b/util/gpool/spmc/spmcpool.go
@@ -392,10 +392,7 @@ func (p *Pool[T, U, C, CT, TF]) retrieveWorker() (w *goWorker[T, U, C, CT, TF])
 
 // revertWorker puts a worker back into free pool, recycling the goroutines.
 func (p *Pool[T, U, C, CT, TF]) revertWorker(worker *goWorker[T, U, C, CT, TF]) bool {
-	if capacity := p.Cap(); capacity > 0 && p.Running() > capacity && p.waitingTask.Load() == 0 {
-		return true
-	}
-	if p.IsClosed() {
+	if capacity := p.Cap(); capacity > 0 && p.Running() > capacity || p.IsClosed() {
 		p.cond.Broadcast()
 		return false
 	}