From 5cb0463cf66d95492c2f939cfeed276ac3f1b9dd Mon Sep 17 00:00:00 2001 From: Fu Diwei Date: Wed, 7 May 2025 15:30:25 +0800 Subject: [PATCH] feat: set the default max workers to the number of available CPU cores --- internal/workflow/dispatcher/dispatcher.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/internal/workflow/dispatcher/dispatcher.go b/internal/workflow/dispatcher/dispatcher.go index 33aa1e0d..f25fadcf 100644 --- a/internal/workflow/dispatcher/dispatcher.go +++ b/internal/workflow/dispatcher/dispatcher.go @@ -5,6 +5,7 @@ import ( "errors" "fmt" "os" + "runtime" "strconv" "sync" "time" @@ -14,7 +15,7 @@ import ( sliceutil "github.com/usual2970/certimate/internal/pkg/utils/slice" ) -var maxWorkers = 16 +var maxWorkers = runtime.NumCPU() func init() { envMaxWorkers := os.Getenv("CERTIMATE_WORKFLOW_MAX_WORKERS")