From 434713a2c355aa5b8685d8f73e7b61f889fa73ea Mon Sep 17 00:00:00 2001 From: Mario Kostelac Date: Sat, 13 Aug 2016 21:29:08 +0100 Subject: [PATCH] Remove delaying dispatcher when all workers are busy --- lib/shoryuken/manager.rb | 6 ------ 1 file changed, 6 deletions(-) diff --git a/lib/shoryuken/manager.rb b/lib/shoryuken/manager.rb index 87b5815b..2a38fdb2 100644 --- a/lib/shoryuken/manager.rb +++ b/lib/shoryuken/manager.rb @@ -104,12 +104,6 @@ def dispatch logger.debug { "Ready: #{@ready.size}, Busy: #{@busy.size}, Active Queues: #{polling_strategy.active_queues}" } - if @ready.empty? - logger.debug { 'Pausing fetcher, because all processors are busy' } - after(1) { dispatch } - return - end - queue = polling_strategy.next_queue if queue.nil? logger.debug { 'Pausing fetcher, because all queues are paused' }