class Threasy::Work::TimeoutQueue

Public Class Methods

new() click to toggle source
# File lib/threasy/work.rb, line 122
def initialize
  @queue = Queue.new
end

Public Instance Methods

clear() click to toggle source
# File lib/threasy/work.rb, line 141
def clear
  @queue.clear
end
pop(seconds = 5) click to toggle source
# File lib/threasy/work.rb, line 131
def pop(seconds = 5)
  timeout(seconds) { @queue.pop }
rescue Timeout::Error
  nil
end
push(item) click to toggle source
# File lib/threasy/work.rb, line 126
def push(item)
  @queue << item
  true
end
size() click to toggle source
# File lib/threasy/work.rb, line 137
def size
  @queue.size
end