# File lib/deep_test/distributed/throughput_runner.rb, line 19 19: def process_work_units 20: @start_time = Time.now 21: 22: @test_count.times do 23: blackboard.write_work NullWorkUnit.new 24: end 25: 26: results_read = 0 27: until results_read == @test_count 28: Thread.pass 29: result = blackboard.take_result 30: if result 31: results_read += 1 32: @progress_block.call(result) if @progress_block 33: end 34: end 35: 36: @end_time = Time.now 37: 38: true 39: end