Class: Asynchronic::QueueEngine::InMemory::Queue

Inherits:

Object

• Object
• Asynchronic::QueueEngine::InMemory::Queue

Extended by:

Forwardable

Defined in:

lib/asynchronic/queue_engine/in_memory.rb

Instance Method Summary

• #initialize ⇒ Queue constructor

  A new instance of Queue.

• #pop ⇒ Object
• #push(message) ⇒ Object

Constructor Details

#initialize ⇒ Queue

Returns a new instance of Queue.

# File 'lib/asynchronic/queue_engine/in_memory.rb', line 49

def initialize
  @queue = []
  @mutex = Mutex.new
end

Instance Method Details

#pop ⇒ Object

# File 'lib/asynchronic/queue_engine/in_memory.rb', line 54

def pop
  mutex.synchronize { queue.shift }
end

#push(message) ⇒ Object

# File 'lib/asynchronic/queue_engine/in_memory.rb', line 58

def push(message)
  mutex.synchronize { queue.push message }
end