Sha256: 664269df98dc6143e1db69559269fee77cc3affedd66826bd0585401f80ccc33
Contents?: true
Size: 1.2 KB
Versions: 12
Compression:
Stored size: 1.2 KB
Contents
module Daemonizer
class WorkerPool
attr_reader :name, :logger
def initialize(name, pm, engine, &blk)
@name = name
@pm = pm
@worker_block = blk
@engine = engine
@workers = []
@logger = @pm.logger
end
def shutdown?
@pm.shutdown?
end
def start_workers(number)
logger.debug "Creating #{number} workers for #{name} pool..."
number.times do |i|
@workers << Worker.new(name, @pm, @engine, i+1, &@worker_block)
end
end
def check_workers
logger.debug "Checking loop #{name} workers..."
@workers.each do |worker|
next if worker.running? || worker.shutdown?
logger.warn "Worker #{worker.name} is not running. Restart!"
worker.run
end
end
def wait_workers
running = 0
@workers.each do |worker|
next unless worker.running?
running += 1
logger.debug "Worker #{name} is still running (#{worker.pid})"
end
return running
end
def stop_workers(force)
logger.debug "Stopping #{name} pool workers..."
@workers.each do |worker|
next unless worker.running?
worker.stop(force)
end
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems