File: mutable_queue.rb

package info (click to toggle)
ruby-hamster 3.0.0-4
  • links: PTS, VCS
  • area: main
  • in suites: bookworm, forky, sid, trixie
  • size: 1,932 kB
  • sloc: ruby: 16,915; makefile: 4
file content (26 lines) | stat: -rw-r--r-- 438 bytes parent folder | download | duplicates (2) 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
 
require "hamster/deque"
require "hamster/read_copy_update"

module Hamster
  # @api private
  class MutableQueue
    include ReadCopyUpdate

    def self.[](*items)
      MutableQueue.new(Deque[*items])
    end

    def enqueue(item)
      transform { |queue| queue.enqueue(item) }
    end

    def dequeue
      head = nil
      transform do |queue|
        head = queue.head
        queue.dequeue
      end
      head
    end
  end
end