module Kuroko2::Workflow::Processor
Public Class Methods
new()
click to toggle source
# File lib/autoload/kuroko2/workflow/processor.rb, line 4 def initialize @hostname = Socket.gethostname @stop = ServerEngine::BlockingFlag.new @processing = ServerEngine::BlockingFlag.new @workflow = Workflow::Engine.new end
Public Instance Methods
run()
click to toggle source
# File lib/autoload/kuroko2/workflow/processor.rb, line 13 def run Kuroko2.logger = logger Kuroko2.logger.info "[#{@hostname}-#{worker_id}] Start Workflow::Processor" until @stop.wait(1.0) unless @processing.set? begin @processing.set! @workflow.process_all @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
stop()
click to toggle source
# File lib/autoload/kuroko2/workflow/processor.rb, line 33 def stop Kuroko2.logger.info "[#{@hostname}-#{worker_id}] Stop Workflow::Processor" @stop.set! end