Sha256: a64f30d57154b9fddbc26e5940afcfef515a0aebec4d7f907a74ac52ac37ad89
Contents?: true
Size: 492 Bytes
Versions: 26
Compression:
Stored size: 492 Bytes
Contents
module Harness
class Consumer
def consume
Thread.new do
while measurement = queue.pop
begin
ensure
mutex.synchronize { @finished = queue.empty? }
end
end
end
end
def finished?
@finished
end
private
def queue
Harness.queue
end
def adapter
Harness.config.adapter
end
def mutex
Harness.mutex
end
def logger
Harness.logger
end
end
end
Version data entries
26 entries across 26 versions & 1 rubygems