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