require 'thread' #class RequestQueue # def initialize # @mutex = Mutex.new # @cv = ConditionVariable.new # @queue = [] # end # # def pop # @mutex.synchronize { # while(@queue.size invoke wait" # @cv.wait(@mutex) # puts "#after wait" # end …