From 4080c2ddfb502ab322f25c0dc8ff896040339aff Mon Sep 17 00:00:00 2001 From: Jian Qiu Date: Mon, 28 Jul 2025 14:12:18 +0800 Subject: [PATCH] fix: set default worker parameter (#22958) Co-authored-by: Qiu Jian --- pkg/appsrv/workers.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/pkg/appsrv/workers.go b/pkg/appsrv/workers.go index 8d5a12a85a..17c1739ca3 100644 --- a/pkg/appsrv/workers.go +++ b/pkg/appsrv/workers.go @@ -191,6 +191,12 @@ func NewWorkerManager(name string, workerCount int, backlog int, dbWorker bool) } func NewWorkerManagerIgnoreOverflow(name string, workerCount int, backlog int, dbWorker bool, ignoreOverflow bool) *SWorkerManager { + if workerCount <= 0 { + workerCount = 1 + } + if backlog <= 0 { + backlog = 128 + } manager := SWorkerManager{name: name, queue: NewRing(workerCount * backlog), workerCount: workerCount,