BackgrounDRb::ThreadPool

    # File server/lib/bdrb_thread_pool.rb, line 16
16:     def initialize(master,size,logger)
17:       @master = master
18:       @logger = logger
19:       @size = size
20:       @threads = []
21:       @work_queue = Queue.new
22:       @size.times { add_thread }
23:     end

    # File server/lib/bdrb_thread_pool.rb, line 52
52:     def add_thread
53:       @threads << Thread.new do
54:         Thread.current[:job_key] = nil
55:         Thread.current[:persistent_job_id] = nil
56:         while true
57:           task = @work_queue.pop
58:           Thread.current[:job_key] = task.job_key
59:           Thread.current[:persistent_job_id] = task.persistent_job_id
60:           block_result = run_task(task)
61:         end
62:       end
63:     end

    # File server/lib/bdrb_thread_pool.rb, line 45
45:     def defer(method_name,args = nil)
46:       job_key = Thread.current[:job_key]
47:       persistent_job_id = Thread.current[:persistent_job_id]
48:       @work_queue << WorkData.new(args,job_key,method_name,persistent_job_id)
49:     end

    # File server/lib/bdrb_thread_pool.rb, line 66
66:     def run_task task
67:       block_arity = master.method(task.job_method).arity
68:       begin
69:         ActiveRecord::Base.verify_active_connections!
70:         t_data = task.args
71:         result = nil
72:         if block_arity != 0
73:           result = master.send(task.job_method,task.args)
74:         else
75:           result = master.send(task.job_method)
76:         end
77:         return result
78:       rescue
79:         logger.info($!.to_s)
80:         logger.info($!.backtrace.join("\n"))
81:         return nil
82:       end
83:     end