Add a loop to ensure all threads get a chance to start.

jruby · Mar 2, 2016 · fabc2db · fabc2db
1 parent 0f66c40
commit fabc2db
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/test/mri/thread/test_queue.rb b/test/mri/thread/test_queue.rb
@@ -515,7 +515,10 @@ def test_queue_close_multi_multi
       end
     end
 
-    # No dead or finished threads
+    # No dead or finished threads, give up to 10 seconds to start running
+    t = Time.now
+    Thread.pass until Time.now - t > 10 || (consumers + producers).all?{|thr| thr.status =~ /\Arun|sleep\Z/}
+
     assert (consumers + producers).all?{|thr| thr.status =~ /\Arun|sleep\Z/}, 'no threads runnning'
 
     # just exercising the concurrency of the support methods.