Break at end of loop

Author: Juuso Mäyränen

lib/logstash/inputs/redis.rb

@@ -291,7 +291,6 @@ def ensure_workers(output_queue)
     keys = @redis.keys(@key)
     keys.shuffle
     keys.each do |key|
-      break unless threadpool_capacity?
       next if @current_workers.include?(key)
       @current_workers.add(key)
       @threadpool.post do
@@ -301,6 +300,7 @@ def ensure_workers(output_queue)
           @current_workers.delete(key)
         end
       end
+      break unless threadpool_capacity?
     end
   end