Contents

require 'parallel_each.rb'
require 'pp'

describe "Parallelizing each/map" do
  it_should_behave_like "AppSwarm Test"
  it "should work at all" do
    Thread.list.select{|t|t.alive?}.length.should == 1
    ma=[]
    mutex=Mutex.new
    a=(0..10).to_a
    a.p_each{|x|sleep rand(0.3); puts x;
      mutex.synchronize {
        ma<<x 
      }
    }
    while ma.length<a.length
      sleep 0.1
    end
    ma.sort.should == a
    Thread.list.select{|t|t.alive?}.length.should == 1
  end
  it "should work for adding 1 in map" do
    a=(0..10).to_a
    a.p_map do |x|
      sleep rand(0.2)
      x+1
    end.should == a.map{|x|x+1}
    Thread.list.select{|t|t.alive?}.length.should == 1
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
appswarm-0.0.1	lib/appswarm/spec/parallel_each_spec.rb