perf(supplier): 优化任务池动态调整策略

- 修改了任务池扩容条件,从原先的 preTaskPoolCount > WorkerCount()+10 改为 preTaskPoolCount+10 > WorkerCount()
- 调整了任务池扩容数量,从原先的 SetCap(min(preTaskPoolCount, MaxFaceValueConcurrency)) 改为 SetCap(min(preTaskPoolCount+10, MaxFaceValueConcurrency))
-调整了任务池空闲时的默认大小,从原先的20 增加到30
This commit is contained in:
danial
2025-09-08 01:46:04 +08:00
parent 2321eac50b
commit 4d08b11b01

View File

@@ -311,8 +311,8 @@ func (s *OrderPoolServiceImpl) matchOrders(ctx context.Context) {
preTaskPoolCount += int(customerLength)
if preTaskPoolCount > int(s.servicePool.WorkerCount())+10 {
s.servicePool.SetCap(int32(min(float64(preTaskPoolCount), float64(s.config.MaxFaceValueConcurrency))))
if preTaskPoolCount+10 > int(s.servicePool.WorkerCount()) {
s.servicePool.SetCap(int32(min(preTaskPoolCount+10, s.config.MaxFaceValueConcurrency)))
}
for range customerLength {
@@ -328,7 +328,7 @@ func (s *OrderPoolServiceImpl) matchOrders(ctx context.Context) {
}
if preTaskPoolCount == 0 {
s.servicePool.SetCap(20)
s.servicePool.SetCap(30)
}
}
}