class Bundler::Worker

def create_threads
  creation_errors = []
  @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
  rescue ThreadError => e
    creation_errors << e
    nil
  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