Class: Test::Unit::TestSuiteThreadRunner

Inherits:
TestSuiteRunner show all
Defined in:
lib/test/unit/test-suite-thread-runner.rb

Class Method Summary collapse

Instance Method Summary collapse

Methods inherited from TestSuiteRunner

default=, #initialize, n_workers, n_workers=, run

Constructor Details

This class inherits a constructor from Test::Unit::TestSuiteRunner

Class Method Details

.run_all_tests {|TestThreadRunContext.new(self, queue, shutdowns)| ... } ⇒ Object

Yields:



15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
# File 'lib/test/unit/test-suite-thread-runner.rb', line 15

def run_all_tests
  n_workers = TestSuiteRunner.n_workers

  queue = Thread::Queue.new
  shutdowns = []
  yield(TestThreadRunContext.new(self, queue, shutdowns))
  n_workers.times do
    queue << nil
  end

  workers = []
  sub_exceptions = []
  n_workers.times do |i|
    workers << Thread.new(i) do |worker_id|
      begin
        loop do
          task = queue.pop
          break if task.nil?
          catch do |stop_tag|
            task.call(stop_tag)
          end
        end
      rescue Exception => exception
        sub_exceptions << exception
      end
    end
  end
  workers.each(&:join)

  shutdowns.each(&:call)
  sub_exceptions.each do |exception|
    raise exception
  end
end

Instance Method Details

#run(result, run_context: nil, &progress_block) ⇒ Object



51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
# File 'lib/test/unit/test-suite-thread-runner.rb', line 51

def run(result, run_context: nil, &progress_block)
  yield(TestSuite::STARTED, @test_suite.name)
  yield(TestSuite::STARTED_OBJECT, @test_suite)
  run_startup(result)
  run_tests(result, run_context: run_context, &progress_block)
ensure
  run_context.shutdowns << lambda do
    begin
      run_shutdown(result)
    ensure
      yield(TestSuite::FINISHED, @test_suite.name)
      yield(TestSuite::FINISHED_OBJECT, @test_suite)
    end
  end
end