Contents

require_relative '../../test_queue'
require_relative '../runner'

module TestQueue
  class Runner
    class Sample < Runner
      def spawn_workers
        puts "Spawning #@concurrency workers"
        super
      end

      def after_fork(num)
        puts "  -- worker #{num} booted as pid #{$$}"
        super
      end

      def run_worker(iterator)
        sum = 0
        iterator.each do |item|
          puts "  #{item.inspect}"
          sum += item
        end
        sum
      end

      def summarize_worker(worker)
        worker.summary  = worker.output.scan(/^\s*(\d+)/).join(', ')
        worker.failure_output = ''
      end
    end
  end
end

if __FILE__ == $0
  TestQueue::Runner::Sample.new(Array(1..10)).execute
end

__END__

Spawning 4 workers
  -- worker 0 booted as pid 40406
  -- worker 1 booted as pid 40407
  -- worker 2 booted as pid 40408
  -- worker 3 booted as pid 40409

==> Starting ruby test-queue worker [1] (40407)

  2
  5
  8

==> Starting ruby test-queue worker [3] (40409)


==> Starting ruby test-queue worker [2] (40408)

  3
  6
  9

==> Starting ruby test-queue worker [0] (40406)

  1
  4
  7
  10

==> Summary

    [1]                                                 2, 5, 8      in 0.0024s      (pid 40407 exit 15)
    [3]                                                              in 0.0036s      (pid 40409 exit 0)
    [2]                                                 3, 6, 9      in 0.0038s      (pid 40408 exit 18)
    [0]                                             1, 4, 7, 10      in 0.0044s      (pid 40406 exit 22)

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
test-queue-0.7.0	lib/test_queue/runner/sample.rb
test-queue-0.6.0	lib/test_queue/runner/sample.rb