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