@return [String] the name of the worker
Creates a worker pool of specified size
@param size [Integer] Size of pool @param name [String] name the name of the worker @param func [Proc] job to run in inside the worker pool
# File lib/bundler/worker.rb, line 23 def initialize(size, name, func) @name = name @request_queue = Queue.new @response_queue = Queue.new @func = func @threads = Array.new(size) do |i| Thread.start { process_queue(i) }.tap do |thread| thread.name = "#{name} Worker ##{i}" if thread.respond_to?(:name=) end end trap("INT") { abort_threads } end
Retrieves results of job function being executed in worker pool
# File lib/bundler/worker.rb, line 44 def deq result = @response_queue.deq raise result.exception if result.is_a?(WrappedException) result end
Enqueue a request to be executed in the worker pool
@param obj [String] mostly it is name of spec that should be downloaded
# File lib/bundler/worker.rb, line 39 def enq(obj) @request_queue.enq obj end
# File lib/bundler/worker.rb, line 50 def stop stop_threads end
# File lib/bundler/worker.rb, line 77 def abort_threads @threads.each(&:exit) exit 1 end
# File lib/bundler/worker.rb, line 64 def apply_func(obj, i) @func.call(obj, i) rescue Exception => e WrappedException.new(e) end
# File lib/bundler/worker.rb, line 56 def process_queue(i) loop do obj = @request_queue.deq break if obj.equal? POISON @response_queue.enq apply_func(obj, i) end end
Stop the worker threads by sending a poison object down the request queue so as worker threads after retrieving it, shut themselves down
# File lib/bundler/worker.rb, line 72 def stop_threads @threads.each { @request_queue.enq POISON } @threads.each(&:join) end