Contents

module Enumerable

  def threaded_map
    initial_abort_on_exception = Thread.abort_on_exception
    Thread.abort_on_exception ||= true
    threads = []
    each do |object|
      threads << Thread.new { yield object }
    end
    values = threads.map(&:value)
    Thread.abort_on_exception = initial_abort_on_exception
    values
  end

end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
twitter-4.1.2	lib/twitter/core_ext/enumerable.rb