Sha256: f23708c82917558eb26d020c6afdaef95f04050d3b086c1b6945f3ae9643606e
Contents?: true
Size: 1.12 KB
Versions: 20
Compression:
Stored size: 1.12 KB
Contents
module Kuroko2
module Workflow
module Scheduler
def initialize
@hostname = Socket.gethostname
@stop = ServerEngine::BlockingFlag.new
@processing = ServerEngine::BlockingFlag.new
end
def run
Kuroko2.logger = logger
Kuroko2.logger.info "[#{@hostname}-#{worker_id}] Start Workflow::Scheduler"
until @stop.wait(2.0)
unless @processing.set?
begin
@processing.set!
JobSchedule.transaction do
now = Time.current
last_scheduled_time = Tick.fetch_then_update(now)
JobSchedule.launch_scheduled_jobs!(last_scheduled_time, now)
end
@processing.reset!
end
end
end
rescue Exception => e
Kuroko2.logger.fatal("[#{@hostname}-#{worker_id}] #{e.class}: #{e.message}\n" +
e.backtrace.map { |trace| " #{trace}" }.join("\n"))
raise e
end
def stop
Kuroko2.logger.info "[#{@hostname}-#{worker_id}] Stop Workflow::Scheduler"
@stop.set!
end
end
end
end
Version data entries
20 entries across 20 versions & 1 rubygems