class Concurrent::BlockingRingBuffer

def empty?

Returns:
  • (Boolean) - true if buffer is empty, false otherwise 
def empty?
  @mutex.synchronize { @buffer.empty? }
end