def each_threaded(&block) # :yields: Object
      threads = []
      climber.connection_pool.connections.each do |connection|
        threads << Thread.new { connection.send(self.class.enumerator_method, &block) }
      end
      threads.each(&:join)
      return
    end
def each_threaded(&block) # :yields: Object
      threads = []
      climber.connection_pool.connections.each do |connection|
        threads << Thread.new { connection.send(self.class.enumerator_method, &block) }
      end
      threads.each(&:join)
      return
    end
Perform a threaded iteration across all connections in the climber's
 connection pool. This method cannot be used for enumerable enumeration
 because a break called within one of the threads will cause a LocalJumpError.
 This could be fixed, but expected behavior on break varies as to whether
 or not to wait for all threads before returning a result. However, still
 useful for operations that always visit all elements.
 An instance of the element is yielded with each iteration.

   jobs = ClimberEnumerable.new(:each_job)
   instance = jobs.new(climber)
   instance.each_threaded do |job|
     ...
   end