Contents

def par_map(n, things, &block)
  queue = Queue.new
  things.each { |thing| queue << thing }
  threads = (1..n).collect do
    Thread.new do
      begin
        while true
          yield queue.pop(true)
        end
      rescue ThreadError

      end
    end
  end
  threads.each { |t| t.join }
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
ceedling-0.29.1	lib/ceedling/par_map.rb
ceedling-0.29.0	lib/ceedling/par_map.rb