Method: Enumerable#parallel_reject

Defined in:
lib/concurrent/parallel.rb

#parallel_reject(n, &block) ⇒ Object 



40
41
42
43
44
45
46
 
# File 'lib/concurrent/parallel.rb', line 40

def parallel_reject( n, &block )
  parallel_subsets( n ).map do |slice|
    Thread.new { slice.reject &block }
  end.inject( [] ) do |a, thread|
    a.push *thread.value
  end
end