Contents

module GoodJob
  class MultiScheduler
    attr_reader :schedulers

    def initialize(schedulers)
      @schedulers = schedulers
    end

    def shutdown(wait: true)
      schedulers.each { |s| s.shutdown(wait: wait) }
    end

    def shutdown?
      schedulers.all?(&:shutdown?)
    end

    def restart(wait: true)
      schedulers.each { |s| s.restart(wait: wait) }
    end

    def create_thread
      schedulers.all?(&:create_thread)
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
good_job-1.1.3	lib/good_job/multi_scheduler.rb
good_job-1.1.2	lib/good_job/multi_scheduler.rb
good_job-1.1.1	lib/good_job/multi_scheduler.rb