Queue#to_enum( wait_thread )

queue-to_enum.rb

#!/usr/bin/env ruby
# vim: set fileencoding=utf-8 :
$VERBOSE = true
=begin
Queue#to_enum
=end

require 'thread'

class Queue
  def to_enum wait_thread
    class << self
      def each &block
        block[ self.deq ] while wait_thread.alive?
        block[ self.deq ] until self.empty?
      end
    end
    self.extend Enumerable
    self
  end
end