Method: ALib::Util#threadify

Defined in:

lib/alib-0.5.0/util.rb

#threadify(list, n = 4, &b) ⇒ Object

# File 'lib/alib-0.5.0/util.rb', line 1433

def threadify list, n = 4, &b
#--{{{
  n = Integer n
  done = Object.new.freeze
  jobs = Queue.new

  list.each_with_index{|elem, i| jobs.push [elem, i]}
  n.times{ jobs.push done} # mark the end

  consumers = Array.new n

  n.times do |i|
    consumers[i] = Thread.new do
      this = Thread.current
      this.abort_on_exception = true

      loop{
        job = jobs.pop
        this.exit if job == done
        jobs << (job << bcall(b, job))
      }
    end
  end

  consumers.map{|t| t.join}
  jobs.push done

  #sleep 5

  ret = Array.new list.size
  while((job = jobs.pop) != done)
    elem, i, value = job
    ret[i] = value
  end
  ret
#--}}}
end