class Que::ResultQueue
Public Class Methods
new()
click to toggle source
# File lib/que/result_queue.rb, line 8 def initialize @array = [] @mutex = Mutex.new end
Public Instance Methods
clear()
click to toggle source
# File lib/que/result_queue.rb, line 17 def clear sync { @array.pop(@array.size) } end
length()
click to toggle source
# File lib/que/result_queue.rb, line 25 def length sync { @array.length } end
push(item)
click to toggle source
# File lib/que/result_queue.rb, line 13 def push(item) sync { @array.push(item) } end
to_a()
click to toggle source
# File lib/que/result_queue.rb, line 21 def to_a sync { @array.dup } end
Private Instance Methods
sync(&block)
click to toggle source
# File lib/que/result_queue.rb, line 31 def sync(&block) @mutex.synchronize(&block) end