From ae24c25c0eec8269de83ce31fe8ea2e4b10f7c87 Mon Sep 17 00:00:00 2001 From: Mario Kostelac Date: Wed, 25 May 2016 16:48:10 +0100 Subject: [PATCH] Reduce hard timeout wait time --- .ruby-version | 1 + lib/shoryuken/manager.rb | 5 ++++- 2 files changed, 5 insertions(+), 1 deletion(-) create mode 100644 .ruby-version diff --git a/.ruby-version b/.ruby-version new file mode 100644 index 00000000..276cbf9e --- /dev/null +++ b/.ruby-version @@ -0,0 +1 @@ +2.3.0 diff --git a/lib/shoryuken/manager.rb b/lib/shoryuken/manager.rb index f954f04c..055e26b6 100644 --- 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