class Concurrent::BlockingRingBuffer

def initialize(capacity)
  @buffer = RingBuffer.new(capacity)
  @first = @last = 0
  @count = 0
  @mutex = Mutex.new
  @condition = Condition.new
end