From 154d5286d8a1243c150b69a912f93d5341c29974 Mon Sep 17 00:00:00 2001 From: hongkuan Date: Thu, 12 Sep 2024 20:50:13 +0800 Subject: [PATCH] do not start workers when running with blocking execution --- quartz/scheduler.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/quartz/scheduler.go b/quartz/scheduler.go index 560467e..1b161cb 100644 --- a/quartz/scheduler.go +++ b/quartz/scheduler.go @@ -433,7 +433,7 @@ func (sched *StdScheduler) startExecutionLoop(ctx context.Context) { } func (sched *StdScheduler) startWorkers(ctx context.Context) { - if sched.opts.WorkerLimit > 0 { + if !sched.opts.BlockingExecution && sched.opts.WorkerLimit > 0 { logger.Debugf("Starting %d scheduler workers.", sched.opts.WorkerLimit) for i := 0; i < sched.opts.WorkerLimit; i++ { sched.wg.Add(1)