Skip to content

Commit

Permalink
Remove delaying dispatcher when all workers are busy
Browse files Browse the repository at this point in the history
  • Loading branch information
mariokostelac committed Aug 13, 2016
1 parent e69752a commit 434713a
Showing 1 changed file with 0 additions and 6 deletions.
6 changes: 0 additions & 6 deletions lib/shoryuken/manager.rb
Original file line number Diff line number Diff line change
Expand Up @@ -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' }
Expand Down

0 comments on commit 434713a

Please sign in to comment.