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