Contents

require File.expand_path('spec/spec_helper')

class Parallel
  def self.wait_for_threads(threads)
    print ' all joined'
  end
end

begin
  Parallel.map(1..100, :in_threads => 4) do |x|
    print x
    raise 'foo' if x == 1
  end
rescue
  print ' raised'
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
parallel-0.5.7	spec/cases/map_with_threads_and_exceptions.rb
parallel-0.5.6	spec/cases/map_with_threads_and_exceptions.rb
parallel-0.5.5	spec/cases/map_with_threads_and_exceptions.rb
parallel-0.5.4	spec/cases/map_with_threads_and_exceptions.rb
parallel-0.5.3	spec/cases/map_with_threads_and_exceptions.rb
parallel-0.5.2	spec/cases/map_with_threads_and_exceptions.rb
parallel-0.5.1	spec/cases/map_with_threads_and_exceptions.rb