class Bundler::Worker

def create_threads
  creation_errors = []
  @threads = Array.new(@size) do |i|
    begin
      Thread.start { process_queue(i) }.tap do |thread|
        thread.name = "#{name} Worker ##{i}" if thread.respond_to?(:name=)
      end
    rescue ThreadError => e
      creation_errors << e
      nil
    end
  end.compact
  add_interrupt_handler unless @threads.empty?
  return if creation_errors.empty?
  message = "Failed to create threads for the #{name} worker: #{creation_errors.map(&:to_s).uniq.join(", ")}"
  raise ThreadCreationError, message if @threads.empty?
  Bundler.ui.info message
end