Adds support for each with concurrency

README.md

@@ -72,6 +72,16 @@ Ost[:rss_feeds].each do |id|
 end
 ```
 
+Each with concurrency
+
+``` ruby
+require "ost"
+
+Ost[:rss_feeds].each_with_concurrency(3) do |id|  #default 3
+  puts "*** #{id} | th: #{Thread.current.object_id}"
+end
+```
+
 It will pop items from the queue as soon as they become available. It
 uses `BRPOPLPUSH` with a timeout that can be specified with the
 `OST_TIMEOUT` environment variable.

lib/ost.rb

@@ -31,6 +31,15 @@ def each(&block)
       end
     end
 
+    def each_with_concurrency(size = 3, &block)
+      concurrency = Array.new(size).map do |iteration|
+        Thread.new(iteration) do |iteration|
+          each(&block)
+        end
+      end
+      concurrency.each(&:join)
+    end
+
     def stop
       @stopping = true
     end