class PArray

Constants

DEFAULT_CONCURRENCY
VERSION

Public Class Methods

new(arr, in_threads:) click to toggle source

# File lib/parray.rb, line 18
def initialize(arr, in_threads:)
  if !arr.respond_to?(:to_a)
    raise Error.new("#{arr} must respond to `#to_a`!")
  end
  @arr        = arr
  @in_threads = in_threads
end

parallelize(arr, in_threads: DEFAULT_CONCURRENCY) click to toggle source

# File lib/parray.rb, line 11
def parallelize(arr, in_threads: DEFAULT_CONCURRENCY)
  PArray.new(arr, in_threads: in_threads)
end

Public Instance Methods

each() { |*args| ... } click to toggle source

# File lib/parray.rb, line 30
def each(&block)
  Parallel.each(@arr.to_a, in_threads: @in_threads) { |*args| yield *args }
end

map() { |*args| ... } click to toggle source

# File lib/parray.rb, line 26
def map(&block)
  Parallel.map(@arr.to_a, in_threads: @in_threads) { |*args| yield *args }
end

to_a() click to toggle source

# File lib/parray.rb, line 34
def to_a
  @arr.to_a
end