Reduce hard timeout wait time

ruby-shoryuken · May 25, 2016 · ae24c25 · ae24c25
1 parent 9f38980
commit ae24c25
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/.ruby-version b/.ruby-version
@@ -0,0 +1 @@
+2.3.0
diff --git a/lib/shoryuken/manager.rb b/lib/shoryuken/manager.rb
@@ -68,6 +68,7 @@ def processor_done(queue, processor)
 
         if stopped?
           processor.terminate if processor.alive?
+          return after(0) { @finished.signal } if @busy.empty?
         else
           @ready << processor
         end
@@ -81,7 +82,9 @@ def processor_died(processor, reason)
         @threads.delete(processor.object_id)
         @busy.delete processor
 
-        unless stopped?
+        if stopped?
+          return after(0) { @finished.signal } if @busy.empty?
+        else
           @ready << build_processor
         end
       end