Sha256: 74558d54ecb7a8c8d5f5a4f249510d873973938abac2e8a9b9a3c5f941ac8396
Contents?: true
Size: 1.8 KB
Versions: 6
Compression:
Stored size: 1.8 KB
Contents
module Bluepill
class Trigger
@implementations = {}
def self.inherited(klass)
@implementations[klass.name.split('::').last.underscore.to_sym] = klass
end
def self.[](name)
@implementations[name]
end
attr_accessor :process, :logger, :mutex, :scheduled_events
def initialize(process, options = {})
self.process = process
self.logger = options[:logger]
self.mutex = Mutex.new
self.scheduled_events = []
end
def reset!
self.cancel_all_events
end
def notify(transition)
raise "Implement in subclass"
end
def dispatch!(event)
self.process.dispatch!(event, self.class.name.split("::").last)
end
def deep_copy
# TODO: This is a kludge. Ideally, process templates
# would be facotries, and not a template object.
mutex, @mutex = @mutex, nil
clone = Marshal.load(Marshal.dump(self))
clone.instance_variable_set("@mutex", Monitor.new)
@mutex = mutex
clone
end
def schedule_event(event, delay)
# TODO: maybe wrap this in a ScheduledEvent class with methods like cancel
thread = Thread.new(self) do |trigger|
begin
sleep delay.to_f
trigger.dispatch!(event)
trigger.mutex.synchronize do
trigger.scheduled_events.delete_if { |_, thread| thread == Thread.current }
end
rescue StandardError => e
trigger.logger.err(e)
trigger.logger.err(e.backtrace.join("\n"))
end
end
self.scheduled_events.push([event, thread])
end
def cancel_all_events
self.logger.info "Canceling all scheduled events"
self.mutex.synchronize do
self.scheduled_events.each {|_, thread| thread.kill}
end
end
end
end
Version data entries
6 entries across 6 versions & 2 rubygems