Sha256: 17b68a6966d4b68d8efeae2051b2de4101311d5bd77f8b252b29e82720ac214f

Contents?: true

Size: 510 Bytes

Versions: 3

Compression:

Stored size: 510 Bytes

Contents

require 'in_threads'

module Enumerable
  # Run enumerable method blocks in threads
  #
  #   urls.in_threads.map do |url|
  #     url.fetch
  #   end
  #
  # Specify number of threads to use:
  #
  #   files.in_threads(4).all? do |file|
  #     file.valid?
  #   end
  #
  # Passing block runs it against <tt>each</tt>
  #
  #   urls.in_threads.each{ … }
  #
  # is same as
  #
  #   urls.in_threads{ … }
  def in_threads(thread_count = 10, &block)
    InThreads.new(self, thread_count, &block)
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version Path
in_threads-1.2.2 lib/in_threads/enumerable.rb
in_threads-1.2.1 lib/in_threads/enumerable.rb
in_threads-1.2.0 lib/in_threads/enumerable.rb