Class: Harness::Consumer

Inherits:
Object
  • Object
show all
Defined in:
lib/harness/consumer.rb

Instance Method Summary collapse

Instance Method Details

#consume ⇒ Object 



3
4
5
6
7
8
9
10
11
12
 
# File 'lib/harness/consumer.rb', line 3

def consume
  Thread.new do
    while measurement = queue.pop
      begin
      ensure
        mutex.synchronize { @finished = queue.empty? }
      end
    end
  end
end

#finished? ⇒ Boolean

Returns:

  • (Boolean) 


14
15
16
 
# File 'lib/harness/consumer.rb', line 14

def finished?
  @finished
end