Run dispatch when processor done or dies

ruby-shoryuken · Jun 4, 2016 · f4640d9 · f4640d9
1 parent 12f0151
commit f4640d9
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/shoryuken/manager.rb b/lib/shoryuken/manager.rb
@@ -71,6 +71,7 @@ def processor_done(queue, processor)
           return after(0) { @finished.signal } if @busy.empty?
         else
           @ready << processor
+          dispatch
         end
       end
     end
@@ -86,6 +87,7 @@ def processor_died(processor, reason)
           return after(0) { @finished.signal } if @busy.empty?
         else
           @ready << build_processor
+          dispatch
         end
       end
     end