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