Contents

require 'forwardable'
require 'hamster/queue'
require 'hamster/experimental/read_copy_update'

module Hamster

  def self.mutable_queue(*items)
    MutableQueue.new(queue(*items))
  end

  class MutableQueue

    extend Forwardable

    include ReadCopyUpdate

    def enqueue(item)
      transform { |queue| queue.enqueue(item) }
    end
    def_delegate :self, :enqueue, :<<
    def_delegate :self, :enqueue, :add

    def dequeue
      head = nil
      transform { |queue|
        head = queue.head
        queue.dequeue
      }
      head
    end

  end

end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
hamster-0.4.3	lib/hamster/experimental/mutable_queue.rb
hamster-0.4.2	lib/hamster/experimental/mutable_queue.rb
hamster-0.4.0	lib/hamster/experimental/mutable_queue.rb