From 809f2319811f55bb801b781459c019e36cbb9dad Mon Sep 17 00:00:00 2001 From: Fu Diwei Date: Wed, 7 May 2025 22:15:11 +0800 Subject: [PATCH] feat: set the default max workers to the number of available CPU cores --- internal/workflow/dispatcher/dispatcher.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/internal/workflow/dispatcher/dispatcher.go b/internal/workflow/dispatcher/dispatcher.go index f25fadcf..7874b945 100644 --- a/internal/workflow/dispatcher/dispatcher.go +++ b/internal/workflow/dispatcher/dispatcher.go @@ -15,12 +15,17 @@ import ( sliceutil "github.com/usual2970/certimate/internal/pkg/utils/slice" ) -var maxWorkers = runtime.NumCPU() +var maxWorkers = 1 func init() { envMaxWorkers := os.Getenv("CERTIMATE_WORKFLOW_MAX_WORKERS") if n, err := strconv.Atoi(envMaxWorkers); err != nil && n > 0 { maxWorkers = n + } else { + maxWorkers = runtime.GOMAXPROCS(0) + if maxWorkers == 0 { + maxWorkers = max(1, runtime.NumCPU()) + } } }