# 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