From 459911a5790b7dc7fea8192b3c28417ae9c6b114 Mon Sep 17 00:00:00 2001 From: Yun Date: Tue, 14 Oct 2025 12:13:28 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E4=B8=80=E4=BA=9B=E9=97=AE?= =?UTF-8?q?=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- cluster.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/cluster.go b/cluster.go index 3a69a89..aa52b20 100644 --- a/cluster.go +++ b/cluster.go @@ -92,8 +92,8 @@ func InitCluster(ctx context.Context, red redis.UniversalClient, keyPrefix strin instanceId: U.String(), cronParser: op.cronParser, batchSize: op.batchSize, - workerChan: make(chan struct{}, op.maxRunCount), - maxWorkers: op.maxRunCount, + workerChan: make(chan struct{}, op.maxWorkers), + maxWorkers: op.maxWorkers, } // 初始化优先级