class Concurrent::BlockingRingBuffer

def wait_while_empty

def wait_while_empty
  @condition.wait(@mutex) while @buffer.empty?
end