Project

General

Profile

Revision df47dd3c

Added by Thomas McKay over 8 years ago

corrected threading

reports updated

removed debug

View differences:

lib/hammer_cli_csv/base.rb
80 80
      option_threads.to_i.times do |current_thread|
81 81
        start_index = ((current_thread) * lines_per_thread).to_i
82 82
        finish_index = ((current_thread + 1) * lines_per_thread).to_i
83
        lines = csv[start_index...finish_index].clone
84
        splits << Thread.new do
85
          lines.each do |line|
86
            if line[NAME][0] != '#'
87
              yield line
83
        finish_index = csv.length if finish_index > csv.length
84
        if start_index <= finish_index
85
          lines = csv[start_index...finish_index].clone
86
          splits << Thread.new do
87
            lines.each do |line|
88
              if line[NAME][0] != '#'
89
                yield line
90
              end
88 91
            end
89 92
          end
90 93
        end

Also available in: Unified diff