This Class is just my exercise to try ConditionVariable in Ruby

blockingqueue.rb

require 'thread'

#This Class is just my exercise to try ConditionVariable
class BlockingQueue

  def initialize
    @queue = Queue.new
    @semaphore = Mutex.new
    @condition = ConditionVariable.new
  end


  def put element
    @queue << element

    @semaphore.synchronize do
      puts 'putting and notifying for ' + element.to_s
      @condition.signal
    end
  end

  def take
    while @queue.empty? do
      @semaphore.synchronize do
        puts 'Waiting on take..'
        @condition.wait(@semaphore)
      end
    end

    i = @queue.pop
    puts 'Taken ' + i.to_s
    i
  end

end

#Testing the above class
Thread.abort_on_exception = true
t = []

lbq = BlockingQueue.new
1.times {
  t << Thread.new {
    loop do
      lbq.take
    end
  }
}

2.times {
  t << Thread.new {
    loop do
      lbq.put rand 100
      sleep 2
    end
  }
}


t.each {|thr| thr.join }