Displaying 1 result from an estimated 1 matches for "new_singleton_work".
Did you mean:
new_singleton_worker
2006 Jul 03
6
Req: Workers as singletons
...klass.to_s.split(''_'').inject('''') { |total,part| total
<< part.capitalize }
@jobs.each do |e|
@logger.debug e.inspect
if e[1].class.name == klasse
return e[0]
end
end
return nil
end
def new_singleton_worker(opts={})
@mutex.synchronize {
worker = get_worker_by_class(opts[:class])
if worker.nil?
job_key = opts[:job_key] || gen_key
unless self[job_key]
self[job_key] = instantiate_worker(opts[:class]).new(opts
[:args])
return job_...