update

Signed-off-by: Weizhen Wang <wangweizhen@pingcap.com>
pingcap · Feb 1, 2023 · 837a6d0 · 837a6d0
1 parent 0ed473b
commit 837a6d0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/util/gpool/spmc/spmcpool.go b/util/gpool/spmc/spmcpool.go
@@ -144,7 +144,7 @@ func (p *Pool[T, U, C, CT, TF]) Tune(size int) {
 	p.capacity.Store(int32(size))
 	if size > capacity {
 		for i := 0; i < size-capacity; i++ {
-			if tid, boostTask := p.taskManager.Overclock(capacity); boostTask != nil {
+			if tid, boostTask := p.taskManager.Overclock(size); boostTask != nil {
 				p.addWaitingTask()
 				newTask := boostTask.Clone()
 				p.taskManager.AddSubTask(tid, newTask)
@@ -159,7 +159,7 @@ func (p *Pool[T, U, C, CT, TF]) Tune(size int) {
 		return
 	}
 	if size < capacity {
-		p.taskManager.Downclock(capacity)
+		p.taskManager.Downclock(size)
 	}
 }