Contents

class MultiThreadedExampleGroupRunner < Spec::Runner::ExampleGroupRunner
  def initialize(options, arg)
    super(options)
    # configure these
    @thread_count = 4
    @thread_wait = 0
  end

  def run
    @threads = []
    q = Queue.new
    example_groups.each { |b| q << b}
    success = true
    @thread_count.times do
      @threads << Thread.new(q) do |queue|
        while not queue.empty?
          example_group = queue.pop
          success &= example_group.suite.run(nil)
        end
      end
      sleep @thread_wait
    end
    @threads.each {|t| t.join}
    success
  end
end

Version data entries

70 entries across 70 versions & 14 rubygems

Version	Path
rspec-1.2.7	examples/passing/multi_threaded_example_group_runner.rb
rspec-1.2.8	examples/passing/multi_threaded_example_group_runner.rb
rspec-1.1.12	examples/passing/multi_threaded_example_group_runner.rb
rspec-1.2.1	examples/passing/multi_threaded_example_group_runner.rb
rspec-1.2.2	examples/passing/multi_threaded_example_group_runner.rb
rspec-1.2.0	examples/passing/multi_threaded_example_group_runner.rb
rspec-1.2.3	examples/passing/multi_threaded_example_group_runner.rb
rspec-1.2.4	examples/passing/multi_threaded_example_group_runner.rb
rspec-1.2.5	examples/passing/multi_threaded_example_group_runner.rb
rspec-1.2.6	examples/passing/multi_threaded_example_group_runner.rb