class Bricolage::TaskQueue
Public Class Methods
new()
click to toggle source
# File lib/bricolage/taskqueue.rb, line 9 def initialize @queue = [] end
Public Instance Methods
consume_each() { |task| ... }
click to toggle source
# File lib/bricolage/taskqueue.rb, line 29 def consume_each lock save while task = self.next yield task deq end ensure unlock end
deq()
click to toggle source
# File lib/bricolage/taskqueue.rb, line 48 def deq task = @queue.shift save task end
each(&block)
click to toggle source
# File lib/bricolage/taskqueue.rb, line 25 def each(&block) @queue.each(&block) end
empty?()
click to toggle source
# File lib/bricolage/taskqueue.rb, line 13 def empty? @queue.empty? end
enq(task)
click to toggle source
# File lib/bricolage/taskqueue.rb, line 40 def enq(task) @queue.push task end
lock()
click to toggle source
# File lib/bricolage/taskqueue.rb, line 64 def lock end
locked?()
click to toggle source
# File lib/bricolage/taskqueue.rb, line 60 def locked? false end
next()
click to toggle source
# File lib/bricolage/taskqueue.rb, line 44 def next @queue.first end
queued?()
click to toggle source
# File lib/bricolage/taskqueue.rb, line 21 def queued? not empty? end
restore()
click to toggle source
# File lib/bricolage/taskqueue.rb, line 57 def restore end
save()
click to toggle source
# File lib/bricolage/taskqueue.rb, line 54 def save end
size()
click to toggle source
# File lib/bricolage/taskqueue.rb, line 17 def size @queue.size end
unlock()
click to toggle source
# File lib/bricolage/taskqueue.rb, line 67 def unlock end
unlock_help()
click to toggle source
# File lib/bricolage/taskqueue.rb, line 70 def unlock_help "[MUST NOT HAPPEN] this message must not be shown" end