Class: PPool::TimeStats
- Inherits:
-
Object
- Object
- PPool::TimeStats
- Defined in:
- lib/time_stats.rb
Instance Method Summary collapse
- #average_elapsed_time ⇒ Object
-
#initialize(average_size) ⇒ TimeStats
constructor
A new instance of TimeStats.
- #is_unlimited ⇒ Object
- #process_ended(pid) ⇒ Object
- #process_started(pid) ⇒ Object
Constructor Details
#initialize(average_size) ⇒ TimeStats
Returns a new instance of TimeStats.
29 30 31 32 33 34 35 |
# File 'lib/time_stats.rb', line 29 def initialize(average_size) @average_size = average_size @start_time = {} @process_count = 0 @elapsed_time = {} @total_elapsed = 0 end |
Instance Method Details
#average_elapsed_time ⇒ Object
57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 |
# File 'lib/time_stats.rb', line 57 def average_elapsed_time() if is_unlimited if @process_count == 0 return 0 end return (@total_elapsed / @process_count).round else size = @elapsed_time.size if size == 0 return 0 end total = @elapsed_time.inject(0) { |t, v| t = t + v[1] } return (total / size).round end end |
#is_unlimited ⇒ Object
80 81 82 |
# File 'lib/time_stats.rb', line 80 def is_unlimited return @average_size == 0 end |
#process_ended(pid) ⇒ Object
43 44 45 46 47 48 49 50 51 52 53 54 |
# File 'lib/time_stats.rb', line 43 def process_ended(pid) elapsed_time = (Time.now - @start_time.delete(pid)) * 1000 if is_unlimited @total_elapsed = @total_elapsed + elapsed_time @process_count = @process_count + 1 else i = @process_count % @average_size @process_count = @process_count + 1 @elapsed_time[i] = elapsed_time end end |
#process_started(pid) ⇒ Object
38 39 40 |
# File 'lib/time_stats.rb', line 38 def process_started(pid) @start_time[pid] = Time.now end |