diff options
Diffstat (limited to 'benchmark/lib/benchmark_driver/runner/ractor.rb')
| -rw-r--r-- | benchmark/lib/benchmark_driver/runner/ractor.rb | 27 |
1 files changed, 15 insertions, 12 deletions
diff --git a/benchmark/lib/benchmark_driver/runner/ractor.rb b/benchmark/lib/benchmark_driver/runner/ractor.rb index 15893b45cf..c730b8e4a5 100644 --- a/benchmark/lib/benchmark_driver/runner/ractor.rb +++ b/benchmark/lib/benchmark_driver/runner/ractor.rb @@ -66,29 +66,32 @@ Warning[:experimental] = false #{prelude} if #{loop_count} == 1 - __bmdv_empty_before = 0 - __bmdv_empty_after = 0 + __bmdv_loop_before = 0 + __bmdv_loop_after = 0 else - __bmdv_empty_before = Time.new + __bmdv_loop_before = Time.new #{while_loop('', loop_count, id: 0)} - __bmdv_empty_after = Time.new + __bmdv_loop_after = Time.new end -ractors = [] -<% results.each do |result| %> -ractors << Ractor.new(__bmdv_empty_after - __bmdv_empty_before) { |loop_time| +__bmdv_ractors = [] +<% results.size.times do %> +__bmdv_ractors << Ractor.new(__bmdv_loop_after - __bmdv_loop_before) { |__bmdv_loop_time| __bmdv_time = Time __bmdv_script_before = __bmdv_time.new #{while_loop(script, loop_count, id: 1)} __bmdv_script_after = __bmdv_time.new - File.write( - <%= result.dump %>, - ((__bmdv_script_after - __bmdv_script_before) - loop_time).inspect, - ) + (__bmdv_script_after - __bmdv_script_before) - __bmdv_loop_time } <% end %> -ractors.each(&:take) + +# Wait for all Ractors before executing code to write results +__bmdv_ractors.map!(&:take) + +<% results.each do |result| %> +File.write(<%= result.dump %>, __bmdv_ractors.shift) +<% end %> #{teardown} RUBY |