Sha256: d9f25132e3ca1c354f9038907b1c417d1cf59fdb0d0e985e286f9bd9f966daf0

Contents?: true

Size: 555 Bytes

Versions: 4

Compression:

Stored size: 555 Bytes

Contents

# frozen_string_literal: true

module Chequeo
  class Manager

    attr_reader :workers

    def initialize
      Chequeo.config.logger.debug "Creating Worker Pool"
      @workers ||= []

      Chequeo.config.workers.times do
        @workers << Chequeo::CheckupProcessor.new
      end
      Chequeo.config.logger.debug "Creating Worker Pool"
    end

    def process
      Chequeo.config.logger.debug "Starting Worker Pool"
      @workers.each do |w|
        w.process
      end
      Chequeo.config.logger.debug "Starting Worker Pool"
    end

  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
chequeo-0.2.3.beta lib/chequeo/manager.rb
chequeo-0.2.2.beta lib/chequeo/manager.rb
chequeo-0.2.1.beta lib/chequeo/manager.rb
chequeo-0.2.0.beta lib/chequeo/manager.rb