diff --git a/processor.go b/processor.go index 925b9c9..d271cdc 100644 --- a/processor.go +++ b/processor.go @@ -179,7 +179,7 @@ func (p *processor) exec() { // Sleep to avoid slamming redis and let scheduler move tasks into queues. // Note: We are not using blocking pop operation and polling queues instead. // This adds significant load to redis. - time.Sleep(time.Second) + time.Sleep(time.Millisecond * 100) <-p.sema // release token return case err != nil: