class ParallelTests::Grouper

Public Class Methods

in_even_groups_by_size(items_with_sizes, num_groups, options={}) click to toggle source
# File lib/parallel_tests/grouper.rb, line 17
def self.in_even_groups_by_size(items_with_sizes, num_groups, options={})
  groups = Array.new(num_groups){{:items => [], :size => 0}}

  # add all files that should run in a single process to one group
  (options[:single_process]||[]).each do |pattern|
    matched, items_with_sizes = items_with_sizes.partition{|item, size| item =~ pattern }
    smallest = smallest_group(groups)
    matched.each{|item,size| add_to_group(smallest, item, size) }
  end

  # add all other files
  largest_first(items_with_sizes).each do |item, size|
    smallest = smallest_group(groups)
    add_to_group(smallest, item, size)
  end

  groups.map!{|g| g[:items].sort }
end
in_groups(items, num_groups) click to toggle source
# File lib/parallel_tests/grouper.rb, line 3
def self.in_groups(items, num_groups)
  groups = Array.new(num_groups){ [] }

  until items.empty?
    num_groups.times do |group_number|
      if item = items.shift
        groups[group_number] << item
      end
    end
  end

  groups.map!(&:sort!)
end
largest_first(files) click to toggle source
# File lib/parallel_tests/grouper.rb, line 36
def self.largest_first(files)
  files.sort_by{|item, size| size }.reverse
end