[tests] Fix threading issue with parallel testing with non-threadsafe rspec mocks

Author: chadlwilson

src/spec/ruby/rack/application_spec.rb

@@ -558,7 +558,7 @@ def createRackServletWrapper(runtime, rackup, filename)
 describe org.jruby.rack.PoolingRackApplicationFactory do
 
   before :each do
-    @factory = double "factory"
+    @factory = double("factory").as_null_object
     @pooling_factory = org.jruby.rack.PoolingRackApplicationFactory.new @factory
     @pooling_factory.context = @rack_context
   end
@@ -641,7 +641,7 @@ def createRackServletWrapper(runtime, rackup, filename)
   it "forces the maximum size to be greater or equal to the initial size" do
     allow(@factory).to receive(:init)
     allow(@factory).to receive(:newApplication) do
-      app = double "app"
+      app = double("app").as_null_object
       expect(app).to receive(:init)
       app
     end
@@ -655,15 +655,15 @@ def createRackServletWrapper(runtime, rackup, filename)
   end
 
   it "retrieves the error application from the delegate factory" do
-    app = double("app")
+    app = double("app").as_null_object
     expect(@factory).to receive(:getErrorApplication).and_return app
     expect(@pooling_factory.getErrorApplication).to eq app
   end
 
   it "waits till initial runtimes get initialized (with wait set to true)" do
     allow(@factory).to receive(:init)
     allow(@factory).to receive(:newApplication) do
-      app = double "app"
+      app = double("app").as_null_object
       allow(app).to receive(:init) do
         sleep(0.05)
       end
@@ -683,7 +683,7 @@ def createRackServletWrapper(runtime, rackup, filename)
     allow(@factory).to receive(:init)
     app_count = java.util.concurrent.atomic.AtomicInteger.new(0)
     allow(@factory).to receive(:newApplication) do
-      app = double "app"
+      app = double("app").as_null_object
       allow(app).to receive(:init) do
         if app_count.addAndGet(1) == 2
           raise org.jruby.rack.RackInitializationException.new('failed app init')
@@ -721,7 +721,7 @@ def createRackServletWrapper(runtime, rackup, filename)
     app_init_millis = 200
     allow(@factory).to receive(:init)
     allow(@factory).to receive(:newApplication) do
-      app = double "app"
+      app = double("app").as_null_object
       allow(app).to receive(:init) { sleep(app_init_millis.to_f / 1000) }
       app
     end
@@ -739,7 +739,7 @@ def createRackServletWrapper(runtime, rackup, filename)
     app_init_millis = 200
     allow(@factory).to receive(:init)
     expect(@factory).to receive(:newApplication).twice do
-      app = double "app"
+      app = double("app").as_null_object
       expect(app).to receive(:init) { sleep(app_init_millis.to_f / 1000) }
       app
     end
@@ -768,7 +768,7 @@ def createRackServletWrapper(runtime, rackup, filename)
     app_init_millis = 100
     allow(@factory).to receive(:init)
     expect(@factory).to receive(:newApplication).twice do
-      app = double "app (new)"
+      app = double("app (new)").as_null_object
       expect(app).to receive(:init) { sleep(app_init_millis.to_f / 1000) }
       app
     end
@@ -784,7 +784,7 @@ def createRackServletWrapper(runtime, rackup, filename)
 
     app_get_millis = 150
     expect(@factory).to receive(:getApplication).twice do
-      app = double "app (get)"; sleep(app_get_millis.to_f / 1000); app
+      app = double("app (get)").as_null_object; sleep(app_get_millis.to_f / 1000); app
     end
 
     start = java.lang.System.currentTimeMillis
@@ -798,34 +798,41 @@ def createRackServletWrapper(runtime, rackup, filename)
     expect(java.lang.System.currentTimeMillis - start).to be_within(20).of(timeout_millis)
   end
 
-  it "initializes initial runtimes in paralel (with wait set to false)" do
+  it "initializes initial runtimes in parallel (with wait set to false)" do
+    @pooling_factory = org.jruby.rack.PoolingRackApplicationFactory.new @factory
+    @pooling_factory.context = @rack_context
+
+    app_init_secs = 0.15
     allow(@factory).to receive(:init)
     allow(@factory).to receive(:newApplication) do
-      app = double "app"
-      allow(app).to receive(:init) do
-        sleep(0.15)
-      end
+      app = double("app").as_null_object
+      allow(app).to receive(:init) { sleep(app_init_secs) }
       app
     end
+
+    init_threads = 4
+    init_runtimes = 6
     allow(@rack_config).to receive(:getBooleanProperty).with("jruby.runtime.init.wait").and_return false
-    allow(@rack_config).to receive(:getInitialRuntimes).and_return 6
+    allow(@rack_config).to receive(:getRuntimeInitThreads).and_return init_threads
+    allow(@rack_config).to receive(:getInitialRuntimes).and_return init_runtimes
     allow(@rack_config).to receive(:getMaximumRuntimes).and_return 8
 
+    expected_initial_init_time = 1.1 * (init_runtimes.to_f / init_threads.to_f).ceil * app_init_secs # 10% margin
     @pooling_factory.init(@rack_context)
-    sleep(0.10)
-    expect(@pooling_factory.getApplicationPool.size).to be < 6
-    sleep(0.9)
-    expect(@pooling_factory.getApplicationPool.size).to be >= 6
+    sleep(app_init_secs) # wait for at some (but not possibly all) to finish
+    expect(@pooling_factory.getApplicationPool.size).to be < init_runtimes
+    sleep(expected_initial_init_time - app_init_secs) # remaining time
+    expect(@pooling_factory.getApplicationPool.size).to be >= init_runtimes
 
     expect(@pooling_factory.getManagedApplications).to_not be_empty
-    expect(@pooling_factory.getManagedApplications.size).to eql 6
+    expect(@pooling_factory.getManagedApplications.size).to eql init_runtimes
   end
 
   it "throws from init when application initialization in thread failed" do
     app_init_secs = 0.05
     allow(@factory).to receive(:init)
     allow(@factory).to receive(:newApplication) do
-      app = double "app"
+      app = double("app").as_null_object
       allow(app).to receive(:init) { sleep(app_init_secs); raise "app.init raising" }
       app
     end