Contents

module Larva
  class WorkerPool
    def self.start(processors)
      new(processors).start
    end

    attr_reader :processors, :workers
    def initialize(processors)
      @processors = processors
    end

    def start
      start_workers
      keep_workers_alive if workers.count > 0
    end

    private
    def start_workers
      logger.info "Starting threads."
      @workers = processors.map do |topic, processor|
        Thread.new { start_worker(topic, processor) }
      end
      logger.info "Threads Started."
    end

    def start_worker(topic, processor)
      Larva::Listener.listen(topic, processor)
    rescue => e
      logger.error "Unexpected listener termination: #{e} #{e.backtrace}"
    end

    def keep_workers_alive
      sleep(5) while workers.all? { |t| t.alive?  }
      logger.error "Some threads have died"
    end

    def logger
      Propono.config.logger
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
larva-0.6.4	lib/larva/worker_pool.rb
larva-0.6.3	lib/larva/worker_pool.rb
larva-0.6.2	lib/larva/worker_pool.rb
larva-0.6.1	lib/larva/worker_pool.rb
larva-0.6.0	lib/larva/worker_pool.rb
larva-0.5.0	lib/larva/worker_pool.rb