lib/shoryuken/launcher.rb in shoryuken-5.2.3 vs lib/shoryuken/launcher.rb in shoryuken-5.3.0
- old
+ new
@@ -30,9 +30,16 @@
executor.shutdown
executor.wait_for_termination
end
+ def healthy?
+ Shoryuken.groups.keys.all? do |group|
+ manager = @managers.find { |m| m.group == group }
+ manager && manager.running?
+ end
+ end
+
private
def executor
@_executor ||= Shoryuken.launcher_executor || Concurrent.global_io_executor
end