Sha256: ffb9f0dc04815a515a9eddfdab7823f8b697d46c8ae66bacb1ee77b4fef35c62

Contents?: true

Size: 296 Bytes

Versions: 26

Compression:

Stored size: 296 Bytes

Contents

require File.expand_path('spec/spec_helper')

begin
  Parallel.map(1..100, :in_processes => 4) do |x|
    sleep 0.1 # so all processes get started
    print x
    raise 'foo' if x == 1
    sleep 0.1 # so no now work gets queued before exception is raised
    x
  end
rescue
  print ' raised'
end

Version data entries

26 entries across 26 versions & 1 rubygems

Version Path
parallel-0.8.3 spec/cases/map_with_processes_and_exceptions.rb
parallel-0.8.2 spec/cases/map_with_processes_and_exceptions.rb
parallel-0.8.1 spec/cases/map_with_processes_and_exceptions.rb
parallel-0.8.0 spec/cases/map_with_processes_and_exceptions.rb
parallel-0.7.1 spec/cases/map_with_processes_and_exceptions.rb
parallel-0.7.0 spec/cases/map_with_processes_and_exceptions.rb
parallel-0.6.5 spec/cases/map_with_processes_and_exceptions.rb
parallel-0.6.4 spec/cases/map_with_processes_and_exceptions.rb
parallel-0.6.3 spec/cases/map_with_processes_and_exceptions.rb
parallel-0.6.2 spec/cases/map_with_processes_and_exceptions.rb
parallel-0.6.1 spec/cases/map_with_processes_and_exceptions.rb
parallel-0.6.0 spec/cases/map_with_processes_and_exceptions.rb
parallel-0.5.21 spec/cases/map_with_processes_and_exceptions.rb
parallel-0.5.20 spec/cases/map_with_processes_and_exceptions.rb
parallel-0.5.19 spec/cases/map_with_processes_and_exceptions.rb
parallel-0.5.18 spec/cases/map_with_processes_and_exceptions.rb
parallel-0.5.17 spec/cases/map_with_processes_and_exceptions.rb
parallel-0.5.16 spec/cases/map_with_processes_and_exceptions.rb
parallel-0.5.15 spec/cases/map_with_processes_and_exceptions.rb
parallel-0.5.14 spec/cases/map_with_processes_and_exceptions.rb