lib/bundler/parallel_workers/thread_worker.rb


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

module Bundler
  module ParallelWorkers
    class ThreadWorker < Worker

      private

      # On platforms where fork is not available
      # use Threads for parallely downloading gems
      #
      # @param size [Integer] Size of thread worker pool
      # @param func [Proc] Job to be run inside thread worker pool
      def prepare_workers(size, func)
        @threads = size.times.map do |i|
          Thread.start do
            Thread.current.abort_on_exception = true
            loop do
              obj = @request_queue.deq
              break if obj.equal? POISON
              @response_queue.enq func.call(obj)
            end
          end
        end
      end

    end
  end
end