parallel.rb

require 'minitest/unit'
require 'drb'
require 'rinda/tuplespace'

module MiniTest
  class ParallelRunner < MiniTest::Unit
    URI = 'druby://127.0.0.1:12345'

    def _run_suites suites, type
      hash = Hash[suites.map { |s| [s.name, s] }]

      queue = fork {
        ts = Rinda::TupleSpace.new
        DRb.start_service URI, ts
        puts DRb.uri
        DRb.thread.join
      }

      children = 3.times.map {
        fork { # consumer
          DRb.start_service
          ts = DRbObject.new_with_uri URI
          loop do
            _, name, type = ts.take ['run', nil, nil]
            result = _run_suite hash[name], type
            ts.write ['finished', result]
          end
        }
      }

      children << queue

      DRb.start_service
      ts = DRbObject.new_with_uri URI
      suites.each { |suite| ts.write ['run', suite.name, type] }

      x = suites.map { ts.take(['finished', nil])[1] }
      Process.kill('KILL', *children)
      x
    end
  end
end

MiniTest::Unit.runner = MiniTest::ParallelRunner.new

知らないです。教えて下さい。 😄