class Asynchronic::QueueEngine::InMemory::Queue

Attributes

mutex[R]
queue[R]

Public Class Methods

new() click to toggle source
# File lib/asynchronic/queue_engine/in_memory.rb, line 49
def initialize
  @queue = []
  @mutex = Mutex.new
end

Public Instance Methods

pop() click to toggle source
# File lib/asynchronic/queue_engine/in_memory.rb, line 54
def pop
  mutex.synchronize { queue.shift }
end
push(message) click to toggle source
# File lib/asynchronic/queue_engine/in_memory.rb, line 58
def push(message)
  mutex.synchronize { queue.push message }
end