Sha256: f67143ee5bc5809a2768df7f110295102a6cca39090383154367f5b1b8f475b7
Contents?: true
Size: 985 Bytes
Versions: 13
Compression:
Stored size: 985 Bytes
Contents
module Minitest
module Parallel
class Executor
attr_reader :size
def initialize size
@size = size
@queue = Queue.new
@pool = size.times.map {
Thread.new(@queue) do |queue|
Thread.current.abort_on_exception = true
while job = queue.pop
klass, method, reporter = job
result = Minitest.run_one_method klass, method
reporter.synchronize { reporter.record result }
end
end
}
end
def << work; @queue << work; end
def shutdown
size.times { @queue << nil }
@pool.each(&:join)
end
end
module Test
def _synchronize; Test.io_lock.synchronize { yield }; end
module ClassMethods
def run_one_method klass, method_name, reporter
Minitest.parallel_executor << [klass, method_name, reporter]
end
def test_order; :parallel; end
end
end
end
end
Version data entries
13 entries across 13 versions & 4 rubygems