Method: Cnvrg::Storage#do_parallel

Defined in:
lib/cnvrg/storage.rb

#do_parallel ⇒ Object 



105
106
107
108
109
110
111
112
 
# File 'lib/cnvrg/storage.rb', line 105

def do_parallel
  Parallel.each( -> { @files.empty? ? (@finished ? Parallel::Stop : sleep(1)) : @files.pop }, in_threads: get_chunks_size) do |file|
    if file == 1
      next
    end
    yield(file)
  end
end