From f4640d97950c1783a061195855d93994725ed64a Mon Sep 17 00:00:00 2001 From: Mario Kostelac Date: Sat, 4 Jun 2016 10:03:47 +0200 Subject: [PATCH] Run dispatch when processor done or dies --- lib/shoryuken/manager.rb | 2 ++ 1 file changed, 2 insertions(+) diff --git a/lib/shoryuken/manager.rb b/lib/shoryuken/manager.rb index 055e26b6..3be96de5 100644 --- 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